service

Documentation

Index

• Variables
• func GRPCUnaryMiddleware(version string, validateReply bool) []grpc.UnaryServerInterceptor
• type QueryService
  • func NewQueryService(db j5query.Transactor, triggerSpec trigger_spb.TriggerPSMQuerySpec) (*QueryService, error)
  • func (qs *QueryService) RegisterGRPC(s grpc.ServiceRegistrar)
• type Service
  • func BuildService(db sqrlx.Transactor) (*Service, error)
  • func (a *Service) RegisterGRPC(server grpc.ServiceRegistrar)
• type TriggerCommand
  • func NewTriggerCommand(db sqrlx.Transactor, sm *trigger_pb.TriggerPSM) (*TriggerCommand, error)
  • func (w *TriggerCommand) ManuallyTrigger(ctx context.Context, req *trigger_spb.ManuallyTriggerRequest) (*trigger_spb.ManuallyTriggerResponse, error)
  • func (w *TriggerCommand) PauseTrigger(ctx context.Context, req *trigger_spb.PauseTriggerRequest) (*trigger_spb.PauseTriggerResponse, error)
  • func (w *TriggerCommand) ResumeTrigger(ctx context.Context, req *trigger_spb.ResumeTriggerRequest) (*trigger_spb.ResumeTriggerResponse, error)
• type TriggerWorker
  • func NewTriggerWorker(db sqrlx.Transactor, sm *trigger_pb.TriggerPSM) (*TriggerWorker, error)
  • func (w TriggerWorker) AllActive(ctx context.Context) ([]*trigger_pb.TriggerState, error)
  • func (w TriggerWorker) GetLastTick(ctx context.Context) (*trigger_tpb.SelfTickMessage, error)
  • func (w TriggerWorker) InitSelfTick(ctx context.Context) error
  • func (w *TriggerWorker) SelfTick(ctx context.Context, req *trigger_tpb.SelfTickMessage) (*emptypb.Empty, error)
  • func (w TriggerWorker) SendSelfTick(ctx context.Context, triggeredTime *time.Time) error
  • func (w *TriggerWorker) TriggerManageRequest(ctx context.Context, req *trigger_tpb.TriggerManageRequestMessage) (*emptypb.Empty, error)

Variables

var ErrNotFound = errors.New("not found")

Functions

func GRPCUnaryMiddleware

func GRPCUnaryMiddleware(version string, validateReply bool) []grpc.UnaryServerInterceptor

Types

type QueryService

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

func NewQueryService

func NewQueryService(db j5query.Transactor,
	triggerSpec trigger_spb.TriggerPSMQuerySpec,
) (*QueryService, error)

func (*QueryService) RegisterGRPC

func (qs *QueryService) RegisterGRPC(s grpc.ServiceRegistrar)

type Service

type Service struct {
	SM             *trigger_pb.TriggerPSM
	QueryService   *QueryService
	TriggerWorker  *TriggerWorker
	TriggerCommand *TriggerCommand
}

func BuildService

func BuildService(db sqrlx.Transactor) (*Service, error)

func (*Service) RegisterGRPC

func (a *Service) RegisterGRPC(server grpc.ServiceRegistrar)

type TriggerCommand

type TriggerCommand struct {
	trigger_spb.UnimplementedTriggerCommandServiceServer
	// contains filtered or unexported fields
}

func NewTriggerCommand

func NewTriggerCommand(db sqrlx.Transactor, sm *trigger_pb.TriggerPSM) (*TriggerCommand, error)

func (*TriggerCommand) ManuallyTrigger

func (w *TriggerCommand) ManuallyTrigger(ctx context.Context, req *trigger_spb.ManuallyTriggerRequest) (*trigger_spb.ManuallyTriggerResponse, error)

func (*TriggerCommand) PauseTrigger

func (w *TriggerCommand) PauseTrigger(ctx context.Context, req *trigger_spb.PauseTriggerRequest) (*trigger_spb.PauseTriggerResponse, error)

func (*TriggerCommand) ResumeTrigger

func (w *TriggerCommand) ResumeTrigger(ctx context.Context, req *trigger_spb.ResumeTriggerRequest) (*trigger_spb.ResumeTriggerResponse, error)

type TriggerWorker

type TriggerWorker struct {
	trigger_tpb.UnimplementedTriggerPublishTopicServer
	trigger_tpb.UnimplementedSelfTickTopicServer
	trigger_tpb.UnimplementedTriggerManageRequestTopicServer
	trigger_tpb.UnimplementedTriggerManageReplyTopicServer
	// contains filtered or unexported fields
}

func NewTriggerWorker

func NewTriggerWorker(db sqrlx.Transactor, sm *trigger_pb.TriggerPSM) (*TriggerWorker, error)

func (TriggerWorker) AllActive

func (w TriggerWorker) AllActive(ctx context.Context) ([]*trigger_pb.TriggerState, error)

func (TriggerWorker) GetLastTick

func (w TriggerWorker) GetLastTick(ctx context.Context) (*trigger_tpb.SelfTickMessage, error)

func (TriggerWorker) InitSelfTick

func (w TriggerWorker) InitSelfTick(ctx context.Context) error

func (*TriggerWorker) SelfTick

func (w *TriggerWorker) SelfTick(ctx context.Context, req *trigger_tpb.SelfTickMessage) (*emptypb.Empty, error)

func (TriggerWorker) SendSelfTick

func (w TriggerWorker) SendSelfTick(ctx context.Context, triggeredTime *time.Time) error

func (*TriggerWorker) TriggerManageRequest

func (w *TriggerWorker) TriggerManageRequest(ctx context.Context, req *trigger_tpb.TriggerManageRequestMessage) (*emptypb.Empty, error)