Documentation ¶
Index ¶
- type AdminService
- type AdminServiceImpl
- 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
- type AdminServiceOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) PutRateLimit ¶ added in v0.19.0
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 ¶ added in v0.9.0
func (a *AdminServiceImpl) TriggerWorkflow(ctx context.Context, req *contracts.TriggerWorkflowRequest) (*contracts.TriggerWorkflowResponse, error)
type AdminServiceOpt ¶
type AdminServiceOpt func(*AdminServiceOpts)
func WithMessageQueue ¶ added in v0.16.0
func WithMessageQueue(mq msgqueue.MessageQueue) AdminServiceOpt
func WithRepository ¶
func WithRepository(r repository.EngineRepository) AdminServiceOpt
func WithValidator ¶ added in v0.21.3
func WithValidator(v validator.Validator) AdminServiceOpt
type AdminServiceOpts ¶
type AdminServiceOpts struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.