pubsub

Documentation

Index

• type Publisher
• type PublisherBase
  • func (p *PublisherBase) Construct(serializer ...message.Serializer)
  • func (p *PublisherBase) Serialize(msg interface{}) ([]byte, error)

Types

type Publisher

type Publisher interface {
	Publish(topicName string, obj interface{}) error
	Shutdown(ctx context.Context) error
}

type PublisherBase

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

func (*PublisherBase) Construct

func (p *PublisherBase) Construct(serializer ...message.Serializer)

func (*PublisherBase) Serialize

func (p *PublisherBase) Serialize(msg interface{}) ([]byte, error)