appevents

type AppEventHandler func(payload []byte, event string)

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

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

type Message interface {
	proto.Message
	// StringType should return a string representation of this
	// protobuf message, which will be used when sending app
	// events through this package.
	StringType() string
}

type ProtoBody struct {
	Payload []byte `json:"payload"`
	Proto   string `json:"proto"`
}

type Topic interface {
	Send(ctx context.Context, message *pubsub.Message) error
}