pubsub

Documentation

Index

• type EventHandler
• type GokaCodec
• type GokaContext
• type GokaEventHandler
• type MessageHeaders
  • func (h MessageHeaders) Add(key, value string)
• type Publisher
• type Subscriber
• type ViewTable

Types

type EventHandler

type EventHandler interface {
	Handle(ctx context.Context, message interface{}) error
}

type GokaCodec

type GokaCodec interface {
	Encode(value interface{}) ([]byte, error)
	Decode(data []byte) (interface{}, error)
}

type GokaContext

type GokaContext interface {
	goka.Context
}

type GokaEventHandler

type GokaEventHandler interface {
	Handle(ctx goka.Context, message interface{})
}

type MessageHeaders

type MessageHeaders map[string]string

func (MessageHeaders) Add

func (h MessageHeaders) Add(key, value string)

type Publisher

type Publisher interface {
	Send(ctx context.Context, key string, message interface{}) error
	Close() error
}

type Subscriber

type Subscriber interface {
	Subscribe()
	Close() error
}

type ViewTable

type ViewTable interface {
	Open()
	Get(key string) (data interface{}, err error)
	Close()
}