types.go

package rpc

import "github.com/streadway/amqp"

type RPC struct {
	uri  string
	conn *amqp.Connection

	name  string
	uuid  string
	token string

	limit int

	connect   chan bool
	reconnect chan bool
	connected chan bool

	done  chan error
	error chan error

	handlers  map[string]Handler
	upstreams map[string]Upstream

	channels  channels
	exchanges exchanges
	queues    queues

	online bool
}

type channels struct {
	common *amqp.Channel
	direct *amqp.Channel
	topic  *amqp.Channel
}
type exchanges struct {
	direct string
	topic  string
}
type queues struct {
	common string
	direct string
	topic  string
}

type Sender struct {
	Name string
	UUID string
}

type Destination struct {
	Name    string
	UUID    string
	Handler string
	All     bool
}

type Receiver struct {
	Name    string
	UUID    string
	Handler string
	All     bool
}

type Handler func(Sender, []byte) error

type Upstream func(Sender, Destination, []byte) error