client

type BadMessageTypeError struct {
	Expected string
	Actual   string
}

type ClientNode struct {
	registry.Node
	proto.MessageClient
	CurrentId string
}

type ClientNodeMapper interface {
	Node(string) (*ClientNode, error)
	AddClientNode(ClientNode)
	RemoveClientNode(string)
	FanClientNodeMessaging(context.Context, messaging.Message, <-chan string) chan registry.Node
}

type ClientNodeOption func(c *ClientNodeOptions) *ClientNodeOptions

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

type ClientRetryOptionsInput struct {
	MaxAttempts     uint
	BackOff         time.Duration
	Jitter          float64
	PerRetryTimeout time.Duration
}

type ContextDoneUnsentMessageError struct {
	MessageId string
}

type ResponseMapper interface {
	PushResponse(messaging.ResponseInfo)
	GenerateIdsByMessage(string) (<-chan string, error)
}

type SubMapper interface {
	AddSubscriber(string, ...string)
	RemoveSubscriber(string, ...string)
	Subscribers(string) ([]string, error)
	GenerateIdsBySubject(string) (<-chan string, error)
}

type UnknownNodeEventError struct {
	Event string
	Id    string
}

type UnregisteredClientNodeError struct {
	Id string
}

type UnregisteredResponseError struct {
	MessageId string
}

type UnregisteredSubjectError struct {
	Subject string
}

type UnregisteredSubscriberError struct {
	Method  string
	Subject string
}