svcrouter

type AttributeFilter struct {
	Compulsory map[string]bool // set to true if compulsory, false if optional
}

type ComparableEnvelope struct {
	Envelope
	// contains filtered or unexported fields
}

type Envelope struct {
	Version    int               `json:"v"` // version of encoded header
	Attributes map[string]string `json:"a"` // attributes
}

type Peer struct {
	PeerDefinition
	// contains filtered or unexported fields
}

type PeerDefinition struct {
	Name    string
	ZmqType zmq.Type
	Address string
	Bind    bool
	PeerImpl
}

type PeerImpl interface {
	GetType() PeerType
	PreDelete(re *RouterElement, peer *Peer)
	PostCreate(re *RouterElement, peer *Peer)
}

type PeerType string

type RouterElement struct {
	// contains filtered or unexported fields
}

type ServerEntry struct {
	Peer     *Peer
	Slk      ServiceLookupKey
	ServerId string
	ShardId  string
	Priority int64
}

type ServiceDispatcher struct {
	EnvRouterPeer   string
	NoEnvRouterPeer string
	ServiceRouter
	*RouterElement
	// contains filtered or unexported fields
}

type ServiceDispatcherPeerImpl struct {
	PeerType PeerType
	// contains filtered or unexported fields
}

type ServiceLookupKey struct {
	ServiceType string
	ServiceId   string
}

type ServiceRouter struct {
	// contains filtered or unexported fields
}