admin

Documentation

Index

• type AdminService
  • func NewAdminService(fs ...AdminServiceOpt) (AdminService, error)
• type AdminServiceImpl
  • func (a *AdminServiceImpl) DeleteWorkflow(ctx context.Context, req *contracts.DeleteWorkflowRequest) (*contracts.Workflow, error)
  • func (a *AdminServiceImpl) GetWorkflowByName(ctx context.Context, req *contracts.GetWorkflowByNameRequest) (*contracts.Workflow, error)
  • func (a *AdminServiceImpl) ListWorkflows(ctx context.Context, req *contracts.ListWorkflowsRequest) (*contracts.ListWorkflowsResponse, error)
  • func (a *AdminServiceImpl) ListWorkflowsForEvent(ctx context.Context, req *contracts.ListWorkflowsForEventRequest) (*contracts.ListWorkflowsResponse, error)
  • func (a *AdminServiceImpl) PutWorkflow(ctx context.Context, req *contracts.PutWorkflowRequest) (*contracts.WorkflowVersion, error)
• type AdminServiceOpt
  • func WithRepository(r repository.Repository) AdminServiceOpt
  • func WithTaskQueue(tq taskqueue.TaskQueue) 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) DeleteWorkflow

func (a *AdminServiceImpl) DeleteWorkflow(ctx context.Context, req *contracts.DeleteWorkflowRequest) (*contracts.Workflow, error)

func (*AdminServiceImpl) GetWorkflowByName

func (a *AdminServiceImpl) GetWorkflowByName(ctx context.Context, req *contracts.GetWorkflowByNameRequest) (*contracts.Workflow, error)

func (*AdminServiceImpl) ListWorkflows

func (a *AdminServiceImpl) ListWorkflows(
	ctx context.Context,
	req *contracts.ListWorkflowsRequest,
) (*contracts.ListWorkflowsResponse, error)

func (*AdminServiceImpl) ListWorkflowsForEvent

func (a *AdminServiceImpl) ListWorkflowsForEvent(
	ctx context.Context,
	req *contracts.ListWorkflowsForEventRequest,
) (*contracts.ListWorkflowsResponse, error)

func (*AdminServiceImpl) PutWorkflow

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

type AdminServiceOpt

type AdminServiceOpt func(*AdminServiceOpts)

func WithRepository

func WithRepository(r repository.Repository) AdminServiceOpt

func WithTaskQueue

func WithTaskQueue(tq taskqueue.TaskQueue) AdminServiceOpt

type AdminServiceOpts

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