bus

Documentation

Index

• Constants
• type ActionDispatcher
• type CoreBus
  • func NewCoreBus() *CoreBus
  • func (c *CoreBus) Broadcast(ctx context.Context, in *coreRpc.EventRequest) (*coreRpc.EventResponse, error)
  • func (c *CoreBus) RegisterAction(name string, in ActionDispatcher)
• type Error
  • func (err Error) Error() string
• type ErrorReason

Constants

const (
	ErrInvalidEventPayload
)

Types

type ActionDispatcher

type ActionDispatcher func(context.Context, *coreRpc.EventRequest) (map[string]interface{}, error)

type CoreBus

type CoreBus struct {
	*coreRpc.UnimplementedBusServiceServer
	// contains filtered or unexported fields
}

func NewCoreBus

func NewCoreBus() *CoreBus

func (*CoreBus) Broadcast

func (c *CoreBus) Broadcast(ctx context.Context, in *coreRpc.EventRequest) (*coreRpc.EventResponse, error)

func (*CoreBus) RegisterAction

func (c *CoreBus) RegisterAction(name string, in ActionDispatcher)

type Error

type Error struct {
	Reason ErrorReason
	Err    error
}

func (Error) Error

func (err Error) Error() string

type ErrorReason

type ErrorReason int