service

Documentation

Index

• Variables
• type ActionServiceWS
  • func NewActionServiceWS(actionTypeService *ActionTypeService) *ActionServiceWS
  • func (s *ActionServiceWS) Start(ctx *context.Context)
  • func (s *ActionServiceWS) Subscribe(sourceID string, names []string) (chan model.Action, error)
  • func (s *ActionServiceWS) Trigger(action model.Action)
  • func (s *ActionServiceWS) Unsubscribe(sourceID string, name string, c chan model.Action) error
• type ActionTypeService
  • func NewActionTypeService(repository *repository.Repository) *ActionTypeService
  • func (s *ActionTypeService) GetActionType(sourceID string, name string) (*model.ActionType, error)
  • func (s *ActionTypeService) GetActionTypes() ([]model.ActionType, error)
  • func (s *ActionTypeService) GetActionTypesBySourceID(sourceID string) ([]model.ActionType, error)
  • func (s *ActionTypeService) RegisterActionType(actionType model.ActionType) (*model.ActionType, error)
• type EventServiceWS
  • func NewEventServiceWS(eventTypeService *EventTypeService) *EventServiceWS
  • func (s *EventServiceWS) Publish(event model.Event)
  • func (s *EventServiceWS) Start(ctx *context.Context)
  • func (s *EventServiceWS) Subscribe(sourceID string, names []string) (chan model.Event, error)
  • func (s *EventServiceWS) Unsubscribe(sourceID string, name string, c chan model.Event) error
• type EventTypeService
  • func NewEventTypeService(repository *repository.Repository) *EventTypeService
  • func (s *EventTypeService) GetEventType(sourceID string, name string) (*model.EventType, error)
  • func (s *EventTypeService) GetEventTypes() ([]model.EventType, error)
  • func (s *EventTypeService) GetEventTypesBySourceID(sourceID string) ([]model.EventType, error)
  • func (s *EventTypeService) RegisterEventType(eventType model.EventType) (*model.EventType, error)
• type MessageBus
  • func NewMessageBus() *MessageBus
• type Services
  • func NewServices(repository *repository.Repository) Services
  • func (s *Services) Start(ctx *context.Context)
• type SocketIOService
  • func NewSocketIOService() *SocketIOService
  • func (s *SocketIOService) Publish(message interface{})
  • func (s *SocketIOService) Server() *socketio.Server
  • func (s *SocketIOService) Start(ctx *context.Context)

Variables

var (
	ErrActionSourceIDNotFound = errors.New("event source id not found")
	ErrActionNameNotFound     = errors.New("event name not found")
)

var (
	ErrEventSourceIDNotFound = errors.New("event source id not found")
	ErrEventNameNotFound     = errors.New("event name not found")
)

var (
	ErrInboundChannelNotFound     = errors.New("inbound channel not found")
	ErrSubscriberChannelsNotFound = errors.New("subscriber channels not found")
	ErrAlreadySubscribed          = errors.New("already subscribed")
)

Types

type ActionServiceWS

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

func NewActionServiceWS

func NewActionServiceWS(actionTypeService *ActionTypeService) *ActionServiceWS

func (*ActionServiceWS) Start

func (s *ActionServiceWS) Start(ctx *context.Context)

func (*ActionServiceWS) Subscribe

func (s *ActionServiceWS) Subscribe(sourceID string, names []string) (chan model.Action, error)

func (*ActionServiceWS) Trigger

func (s *ActionServiceWS) Trigger(action model.Action)

func (*ActionServiceWS) Unsubscribe

func (s *ActionServiceWS) Unsubscribe(sourceID string, name string, c chan model.Action) error

type ActionTypeService

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

func NewActionTypeService

func NewActionTypeService(repository *repository.Repository) *ActionTypeService

func (*ActionTypeService) GetActionType

func (s *ActionTypeService) GetActionType(sourceID string, name string) (*model.ActionType, error)

func (*ActionTypeService) GetActionTypes

func (s *ActionTypeService) GetActionTypes() ([]model.ActionType, error)

func (*ActionTypeService) GetActionTypesBySourceID

func (s *ActionTypeService) GetActionTypesBySourceID(sourceID string) ([]model.ActionType, error)

func (*ActionTypeService) RegisterActionType

func (s *ActionTypeService) RegisterActionType(actionType model.ActionType) (*model.ActionType, error)

type EventServiceWS

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

func NewEventServiceWS

func NewEventServiceWS(eventTypeService *EventTypeService) *EventServiceWS

func (*EventServiceWS) Publish

func (s *EventServiceWS) Publish(event model.Event)

func (*EventServiceWS) Start

func (s *EventServiceWS) Start(ctx *context.Context)

func (*EventServiceWS) Subscribe

func (s *EventServiceWS) Subscribe(sourceID string, names []string) (chan model.Event, error)

func (*EventServiceWS) Unsubscribe

func (s *EventServiceWS) Unsubscribe(sourceID string, name string, c chan model.Event) error

type EventTypeService

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

func NewEventTypeService

func NewEventTypeService(repository *repository.Repository) *EventTypeService

func (*EventTypeService) GetEventType

func (s *EventTypeService) GetEventType(sourceID string, name string) (*model.EventType, error)

func (*EventTypeService) GetEventTypes

func (s *EventTypeService) GetEventTypes() ([]model.EventType, error)

func (*EventTypeService) GetEventTypesBySourceID

func (s *EventTypeService) GetEventTypesBySourceID(sourceID string) ([]model.EventType, error)

func (*EventTypeService) RegisterEventType

func (s *EventTypeService) RegisterEventType(eventType model.EventType) (*model.EventType, error)

type MessageBus

type MessageBus struct{}

func NewMessageBus

func NewMessageBus() *MessageBus

type Services

type Services struct {
	EventTypeService *EventTypeService
	EventServiceWS   *EventServiceWS

	ActionTypeService *ActionTypeService
	ActionServiceWS   *ActionServiceWS

	SocketIOService *SocketIOService
}

func NewServices

func NewServices(repository *repository.Repository) Services

func (*Services) Start

func (s *Services) Start(ctx *context.Context)

type SocketIOService

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

func NewSocketIOService

func NewSocketIOService() *SocketIOService

func (*SocketIOService) Publish

func (s *SocketIOService) Publish(message interface{})

func (*SocketIOService) Server

func (s *SocketIOService) Server() *socketio.Server

func (*SocketIOService) Start

func (s *SocketIOService) Start(ctx *context.Context)