gateway

Documentation

Index

• Constants
• func Init(gatewayAddr string) error
• func NewClient(config *zbc.ClientConfig) (pb.GatewayClient, error)
• type GatewayServerImpl
  • func (*GatewayServerImpl) ActivateJobs(req *pb.ActivateJobsRequest, srv pb.Gateway_ActivateJobsServer) error
  • func (*GatewayServerImpl) CancelWorkflowInstance(ctx context.Context, req *pb.CancelWorkflowInstanceRequest) (*pb.CancelWorkflowInstanceResponse, error)
  • func (*GatewayServerImpl) CompleteJob(ctx context.Context, req *pb.CompleteJobRequest) (*pb.CompleteJobResponse, error)
  • func (*GatewayServerImpl) CreateWorkflowInstance(ctx context.Context, req *pb.CreateWorkflowInstanceRequest) (*pb.CreateWorkflowInstanceResponse, error)
  • func (*GatewayServerImpl) CreateWorkflowInstanceWithResult(ctx context.Context, req *pb.CreateWorkflowInstanceWithResultRequest) (*pb.CreateWorkflowInstanceWithResultResponse, error)
  • func (*GatewayServerImpl) DeployWorkflow(ctx context.Context, req *pb.DeployWorkflowRequest) (*pb.DeployWorkflowResponse, error)
  • func (*GatewayServerImpl) FailJob(ctx context.Context, req *pb.FailJobRequest) (*pb.FailJobResponse, error)
  • func (*GatewayServerImpl) PublishMessage(ctx context.Context, req *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)
  • func (*GatewayServerImpl) ResolveIncident(ctx context.Context, req *pb.ResolveIncidentRequest) (*pb.ResolveIncidentResponse, error)
  • func (*GatewayServerImpl) SetVariables(ctx context.Context, req *pb.SetVariablesRequest) (*pb.SetVariablesResponse, error)
  • func (*GatewayServerImpl) ThrowError(ctx context.Context, req *pb.ThrowErrorRequest) (*pb.ThrowErrorResponse, error)
  • func (s *GatewayServerImpl) Topology(context.Context, *pb.TopologyRequest) (*pb.TopologyResponse, error)
  • func (*GatewayServerImpl) UpdateJobRetries(ctx context.Context, req *pb.UpdateJobRetriesRequest) (*pb.UpdateJobRetriesResponse, error)

Constants

const DefaultKeepAlive = 45 * time.Second

Functions

func Init

func Init(gatewayAddr string) error

func NewClient

func NewClient(config *zbc.ClientConfig) (pb.GatewayClient, error)

Types

type GatewayServerImpl

type GatewayServerImpl struct {
}

func (*GatewayServerImpl) ActivateJobs

func (*GatewayServerImpl) ActivateJobs(req *pb.ActivateJobsRequest, srv pb.Gateway_ActivateJobsServer) error

func (*GatewayServerImpl) CancelWorkflowInstance

func (*GatewayServerImpl) CancelWorkflowInstance(ctx context.Context, req *pb.CancelWorkflowInstanceRequest) (*pb.CancelWorkflowInstanceResponse, error)

func (*GatewayServerImpl) CompleteJob

func (*GatewayServerImpl) CompleteJob(ctx context.Context, req *pb.CompleteJobRequest) (*pb.CompleteJobResponse, error)

func (*GatewayServerImpl) CreateWorkflowInstance

func (*GatewayServerImpl) CreateWorkflowInstance(ctx context.Context, req *pb.CreateWorkflowInstanceRequest) (*pb.CreateWorkflowInstanceResponse, error)

func (*GatewayServerImpl) CreateWorkflowInstanceWithResult

func (*GatewayServerImpl) CreateWorkflowInstanceWithResult(ctx context.Context, req *pb.CreateWorkflowInstanceWithResultRequest) (*pb.CreateWorkflowInstanceWithResultResponse, error)

func (*GatewayServerImpl) DeployWorkflow

func (*GatewayServerImpl) DeployWorkflow(ctx context.Context, req *pb.DeployWorkflowRequest) (*pb.DeployWorkflowResponse, error)

func (*GatewayServerImpl) FailJob

func (*GatewayServerImpl) FailJob(ctx context.Context, req *pb.FailJobRequest) (*pb.FailJobResponse, error)

func (*GatewayServerImpl) PublishMessage

func (*GatewayServerImpl) PublishMessage(ctx context.Context, req *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)

func (*GatewayServerImpl) ResolveIncident

func (*GatewayServerImpl) ResolveIncident(ctx context.Context, req *pb.ResolveIncidentRequest) (*pb.ResolveIncidentResponse, error)

func (*GatewayServerImpl) SetVariables

func (*GatewayServerImpl) SetVariables(ctx context.Context, req *pb.SetVariablesRequest) (*pb.SetVariablesResponse, error)

func (*GatewayServerImpl) ThrowError

func (*GatewayServerImpl) ThrowError(ctx context.Context, req *pb.ThrowErrorRequest) (*pb.ThrowErrorResponse, error)

func (*GatewayServerImpl) Topology

func (s *GatewayServerImpl) Topology(context.Context, *pb.TopologyRequest) (*pb.TopologyResponse, error)

func (*GatewayServerImpl) UpdateJobRetries

func (*GatewayServerImpl) UpdateJobRetries(ctx context.Context, req *pb.UpdateJobRetriesRequest) (*pb.UpdateJobRetriesResponse, error)