admin

Documentation

Index

• type AdminService
  • func NewAdminService(fs ...AdminServiceOpt) (AdminService, error)
• type AdminServiceImpl
  • func (a *AdminServiceImpl) BulkTriggerWorkflow(ctx context.Context, req *contracts.BulkTriggerWorkflowRequest) (*contracts.BulkTriggerWorkflowResponse, error)
  • func (a *AdminServiceImpl) PutRateLimit(ctx context.Context, req *contracts.PutRateLimitRequest) (*contracts.PutRateLimitResponse, error)
  • func (a *AdminServiceImpl) PutWorkflow(ctx context.Context, req *contracts.PutWorkflowRequest) (*contracts.WorkflowVersion, error)
  • func (a *AdminServiceImpl) ScheduleWorkflow(ctx context.Context, req *contracts.ScheduleWorkflowRequest) (*contracts.WorkflowVersion, error)
  • func (a *AdminServiceImpl) TriggerWorkflow(ctx context.Context, req *contracts.TriggerWorkflowRequest) (*contracts.TriggerWorkflowResponse, error)
• type AdminServiceOpt
  • func WithEntitlementsRepository(r repository.EntitlementsRepository) AdminServiceOpt
  • func WithMessageQueue(mq msgqueue.MessageQueue) AdminServiceOpt
  • func WithRepository(r repository.EngineRepository) AdminServiceOpt
  • func WithValidator(v validator.Validator) AdminServiceOpt
• type AdminServiceOpts

Types

type AdminService

type AdminService interface {
	contracts.WorkflowServiceServer
}

func NewAdminService

func NewAdminService(fs ...AdminServiceOpt) (AdminService, error)

type AdminServiceImpl

type AdminServiceImpl struct {
	contracts.UnimplementedWorkflowServiceServer
	// contains filtered or unexported fields
}

func (*AdminServiceImpl) BulkTriggerWorkflow

func (a *AdminServiceImpl) BulkTriggerWorkflow(ctx context.Context, req *contracts.BulkTriggerWorkflowRequest) (*contracts.BulkTriggerWorkflowResponse, error)

func (*AdminServiceImpl) PutRateLimit

func (a *AdminServiceImpl) PutRateLimit(ctx context.Context, req *contracts.PutRateLimitRequest) (*contracts.PutRateLimitResponse, error)

func (*AdminServiceImpl) PutWorkflow

func (a *AdminServiceImpl) PutWorkflow(ctx context.Context, req *contracts.PutWorkflowRequest) (*contracts.WorkflowVersion, error)

func (*AdminServiceImpl) ScheduleWorkflow

func (a *AdminServiceImpl) ScheduleWorkflow(ctx context.Context, req *contracts.ScheduleWorkflowRequest) (*contracts.WorkflowVersion, error)

func (*AdminServiceImpl) TriggerWorkflow

func (a *AdminServiceImpl) TriggerWorkflow(ctx context.Context, req *contracts.TriggerWorkflowRequest) (*contracts.TriggerWorkflowResponse, error)

type AdminServiceOpt

type AdminServiceOpt func(*AdminServiceOpts)

func WithEntitlementsRepository

func WithEntitlementsRepository(r repository.EntitlementsRepository) AdminServiceOpt

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) AdminServiceOpt

func WithRepository

func WithRepository(r repository.EngineRepository) AdminServiceOpt

func WithValidator

func WithValidator(v validator.Validator) AdminServiceOpt

type AdminServiceOpts

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