Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PublisherServer ¶
type PublisherServer struct {
// contains filtered or unexported fields
}
func NewProducerServer ¶
func NewProducerServer(addr string) *PublisherServer
func (PublisherServer) Close ¶
func (ps PublisherServer) Close()
func (PublisherServer) GenerateEventID ¶
func (ps PublisherServer) GenerateEventID() uuid.UUID
func (PublisherServer) Producer ¶
func (ps PublisherServer) Producer(ctx context.Context, input types.PayloadType) error
type SubscriberServer ¶
type SubscriberServer struct {
// contains filtered or unexported fields
}
func NewSubscriberServer ¶
func NewSubscriberServer(addr string, db *sql.DB) *SubscriberServer
func (*SubscriberServer) AddHandlers ¶
func (ss *SubscriberServer) AddHandlers(consumers map[string]types.ConsumerFn) *SubscriberServer
func (*SubscriberServer) Start ¶
func (ss *SubscriberServer) Start() error
Source Files
Click to show internal directories.
Click to hide internal directories.