nproto

type MD interface {
	// Keys iterates all keys in MD.
	Keys(cb func(string) error) error

	// HasKey returns true if MD contains the specified key.
	HasKey(key string) bool

	// Values returns the list of values associated with the specified key or
	// nil if not exists. NOTE: Don't modify the returned slice and its content.
	Values(key string) [][]byte
}

type MetaData map[string][][]byte

type MsgAsyncPublisher interface {
	// PublishAsync publishes a message to the given subject asynchronously.
	// The final result is returned by `cb` if PublishAsync returns nil.
	// `cb` must be called exactly once in this case.
	PublishAsync(ctx context.Context, subject string, msgData []byte, cb func(error)) error
}

type MsgAsyncPublisherFunc func(context.Context, string, []byte, func(error)) error

type MsgAsyncPublisherMiddleware func(MsgAsyncPublisherFunc) MsgAsyncPublisherFunc

type MsgHandler func(context.Context, []byte) error

type MsgMiddleware func(string, string, MsgHandler) MsgHandler

type MsgPublisher interface {
	// Publish publishes a message to the given subject. It returns nil if success.
	Publish(ctx context.Context, subject string, msgData []byte) error
}

type MsgPublisherFunc func(context.Context, string, []byte) error

type MsgPublisherMiddleware func(MsgPublisherFunc) MsgPublisherFunc

type MsgSubscriber interface {
	// Subscribe subscribes to a given subject. One subject can have many queues.
	// In normal case (excpet message redelivery) each message will be delivered to
	// one member of each queue.
	// Order of messages is not guaranteed since redelivery.
	Subscribe(subject, queue string, handler MsgHandler, opts ...interface{}) error
}

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

type PBPublisher struct {
	Publisher MsgPublisher
}

type RPCClient interface {
	// MakeHandler creates a RPCHandler for a given method of a service.
	MakeHandler(svcName string, method *RPCMethod) RPCHandler
}

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

type RPCHandler func(context.Context, proto.Message) (proto.Message, error)

type RPCMethod struct {
	// Name is the name of this method.
	Name string
	// NewInput is used to generate a new input message.
	NewInput func() proto.Message
	// NewOutput is used to generate a new output message.
	NewOutput func() proto.Message
}

type RPCMiddleware func(string, *RPCMethod, RPCHandler) RPCHandler

type RPCServer interface {
	// RegistSvc regist a service with given method set and associated handlers.
	RegistSvc(svcName string, methods map[*RPCMethod]RPCHandler) error

	// DeregistSvc deregist a service.
	DeregistSvc(svcName string) error
}

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