pubsub

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

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

type GokaContext interface {
	goka.Context
}

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

type MessageHeaders map[string]string

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

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

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