subscriber

Documentation

Index

• type CreateSensorDataSubscriber
  • func NewSensorDataSubscriber(tcSvc service.TreeClusterService, treeSvc service.TreeService) *CreateSensorDataSubscriber
  • func (s *CreateSensorDataSubscriber) EventType() entities.EventType
  • func (s *CreateSensorDataSubscriber) HandleEvent(ctx context.Context, e entities.Event) error
• type CreateTreeSubscriber
  • func NewCreateTreeSubscriber(tcs service.TreeClusterService) *CreateTreeSubscriber
  • func (s *CreateTreeSubscriber) EventType() entities.EventType
  • func (s *CreateTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error
• type DeleteTreeSubscriber
  • func NewDeleteTreeSubscriber(tcs service.TreeClusterService) *DeleteTreeSubscriber
  • func (s *DeleteTreeSubscriber) EventType() entities.EventType
  • func (s *DeleteTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error
• type UpdateTreeSubscriber
  • func NewUpdateTreeSubscriber(tcs service.TreeClusterService) *UpdateTreeSubscriber
  • func (s *UpdateTreeSubscriber) EventType() entities.EventType
  • func (s *UpdateTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error
• type UpdateWateringPlanSubscriber
  • func NewUpdateWateringPlanSubscriber(tcSvc service.TreeClusterService) *UpdateWateringPlanSubscriber
  • func (s *UpdateWateringPlanSubscriber) EventType() entities.EventType
  • func (s *UpdateWateringPlanSubscriber) HandleEvent(ctx context.Context, e entities.Event) error

Types

type CreateSensorDataSubscriber

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

func NewSensorDataSubscriber

func NewSensorDataSubscriber(tcSvc service.TreeClusterService, treeSvc service.TreeService) *CreateSensorDataSubscriber

func (*CreateSensorDataSubscriber) EventType

func (s *CreateSensorDataSubscriber) EventType() entities.EventType

func (*CreateSensorDataSubscriber) HandleEvent

func (s *CreateSensorDataSubscriber) HandleEvent(ctx context.Context, e entities.Event) error

type CreateTreeSubscriber

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

func NewCreateTreeSubscriber

func NewCreateTreeSubscriber(tcs service.TreeClusterService) *CreateTreeSubscriber

func (*CreateTreeSubscriber) EventType

func (s *CreateTreeSubscriber) EventType() entities.EventType

func (*CreateTreeSubscriber) HandleEvent

func (s *CreateTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error

type DeleteTreeSubscriber

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

func NewDeleteTreeSubscriber

func NewDeleteTreeSubscriber(tcs service.TreeClusterService) *DeleteTreeSubscriber

func (*DeleteTreeSubscriber) EventType

func (s *DeleteTreeSubscriber) EventType() entities.EventType

func (*DeleteTreeSubscriber) HandleEvent

func (s *DeleteTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error

type UpdateTreeSubscriber

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

func NewUpdateTreeSubscriber

func NewUpdateTreeSubscriber(tcs service.TreeClusterService) *UpdateTreeSubscriber

func (*UpdateTreeSubscriber) EventType

func (s *UpdateTreeSubscriber) EventType() entities.EventType

func (*UpdateTreeSubscriber) HandleEvent

func (s *UpdateTreeSubscriber) HandleEvent(ctx context.Context, e entities.Event) error

type UpdateWateringPlanSubscriber

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

func NewUpdateWateringPlanSubscriber

func NewUpdateWateringPlanSubscriber(tcSvc service.TreeClusterService) *UpdateWateringPlanSubscriber

func (*UpdateWateringPlanSubscriber) EventType

func (s *UpdateWateringPlanSubscriber) EventType() entities.EventType

func (*UpdateWateringPlanSubscriber) HandleEvent

func (s *UpdateWateringPlanSubscriber) HandleEvent(ctx context.Context, e entities.Event) error