Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAutoFlowServer(s grpc.ServiceRegistrar, srv AutoFlowServer)
- type AutoFlowClient
- type AutoFlowServer
- type CloudEventRequest
- func (*CloudEventRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloudEventRequest) GetEvent() *event.CloudEvent
- func (x *CloudEventRequest) GetFlowProject() *event.Project
- func (x *CloudEventRequest) GetVariables() map[string]string
- func (*CloudEventRequest) ProtoMessage()
- func (x *CloudEventRequest) ProtoReflect() protoreflect.Message
- func (x *CloudEventRequest) Reset()
- func (x *CloudEventRequest) String() string
- type CloudEventResponse
- type StartWorkflowRequest
- func (*StartWorkflowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartWorkflowRequest) GetIdentityKey() string
- func (x *StartWorkflowRequest) GetSecrets() []*engine.Secret
- func (x *StartWorkflowRequest) GetWorkflowDefinition() []byte
- func (*StartWorkflowRequest) ProtoMessage()
- func (x *StartWorkflowRequest) ProtoReflect() protoreflect.Message
- func (x *StartWorkflowRequest) Reset()
- func (x *StartWorkflowRequest) String() string
- type StartWorkflowResponse
- func (*StartWorkflowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartWorkflowResponse) GetWorkflowId() string
- func (*StartWorkflowResponse) ProtoMessage()
- func (x *StartWorkflowResponse) ProtoReflect() protoreflect.Message
- func (x *StartWorkflowResponse) Reset()
- func (x *StartWorkflowResponse) String() string
- type UnimplementedAutoFlowServer
- type UnsafeAutoFlowServer
Constants ¶
const ( AutoFlow_CloudEvent_FullMethodName = "/gitlab.agent.autoflow.rpc.AutoFlow/CloudEvent" AutoFlow_StartWorkflow_FullMethodName = "/gitlab.agent.autoflow.rpc.AutoFlow/StartWorkflow" )
Variables ¶
var AutoFlow_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gitlab.agent.autoflow.rpc.AutoFlow", HandlerType: (*AutoFlowServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CloudEvent", Handler: _AutoFlow_CloudEvent_Handler, }, { MethodName: "StartWorkflow", Handler: _AutoFlow_StartWorkflow_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "internal/module/autoflow/rpc/rpc.proto", }
AutoFlow_ServiceDesc is the grpc.ServiceDesc for AutoFlow service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_internal_module_autoflow_rpc_rpc_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAutoFlowServer ¶
func RegisterAutoFlowServer(s grpc.ServiceRegistrar, srv AutoFlowServer)
Types ¶
type AutoFlowClient ¶
type AutoFlowClient interface {
CloudEvent(ctx context.Context, in *CloudEventRequest, opts ...grpc.CallOption) (*CloudEventResponse, error)
StartWorkflow(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*StartWorkflowResponse, error)
}
AutoFlowClient is the client API for AutoFlow service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAutoFlowClient ¶
func NewAutoFlowClient(cc grpc.ClientConnInterface) AutoFlowClient
type AutoFlowServer ¶
type AutoFlowServer interface {
CloudEvent(context.Context, *CloudEventRequest) (*CloudEventResponse, error)
StartWorkflow(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)
// contains filtered or unexported methods
}
AutoFlowServer is the server API for AutoFlow service. All implementations must embed UnimplementedAutoFlowServer for forward compatibility.
type CloudEventRequest ¶
type CloudEventRequest struct {
Event *event.CloudEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
FlowProject *event.Project `protobuf:"bytes,2,opt,name=flow_project,json=flowProject" json:"flow_project,omitempty"`
Variables map[string]string `` /* 138-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CloudEventRequest) Descriptor
deprecated
func (*CloudEventRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloudEventRequest.ProtoReflect.Descriptor instead.
func (*CloudEventRequest) GetEvent ¶
func (x *CloudEventRequest) GetEvent() *event.CloudEvent
func (*CloudEventRequest) GetFlowProject ¶
func (x *CloudEventRequest) GetFlowProject() *event.Project
func (*CloudEventRequest) GetVariables ¶
func (x *CloudEventRequest) GetVariables() map[string]string
func (*CloudEventRequest) ProtoMessage ¶
func (*CloudEventRequest) ProtoMessage()
func (*CloudEventRequest) ProtoReflect ¶
func (x *CloudEventRequest) ProtoReflect() protoreflect.Message
func (*CloudEventRequest) Reset ¶
func (x *CloudEventRequest) Reset()
func (*CloudEventRequest) String ¶
func (x *CloudEventRequest) String() string
type CloudEventResponse ¶
type CloudEventResponse struct {
// contains filtered or unexported fields
}
func (*CloudEventResponse) Descriptor
deprecated
func (*CloudEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloudEventResponse.ProtoReflect.Descriptor instead.
func (*CloudEventResponse) ProtoMessage ¶
func (*CloudEventResponse) ProtoMessage()
func (*CloudEventResponse) ProtoReflect ¶
func (x *CloudEventResponse) ProtoReflect() protoreflect.Message
func (*CloudEventResponse) Reset ¶
func (x *CloudEventResponse) Reset()
func (*CloudEventResponse) String ¶
func (x *CloudEventResponse) String() string
type StartWorkflowRequest ¶
type StartWorkflowRequest struct {
IdentityKey string `protobuf:"bytes,1,opt,name=identity_key,json=identityKey" json:"identity_key,omitempty"`
WorkflowDefinition []byte `protobuf:"bytes,2,opt,name=workflow_definition,json=workflowDefinition" json:"workflow_definition,omitempty"`
Secrets []*engine.Secret `protobuf:"bytes,3,rep,name=secrets" json:"secrets,omitempty"`
// contains filtered or unexported fields
}
func (*StartWorkflowRequest) Descriptor
deprecated
func (*StartWorkflowRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.
func (*StartWorkflowRequest) GetIdentityKey ¶
func (x *StartWorkflowRequest) GetIdentityKey() string
func (*StartWorkflowRequest) GetSecrets ¶
func (x *StartWorkflowRequest) GetSecrets() []*engine.Secret
func (*StartWorkflowRequest) GetWorkflowDefinition ¶
func (x *StartWorkflowRequest) GetWorkflowDefinition() []byte
func (*StartWorkflowRequest) ProtoMessage ¶
func (*StartWorkflowRequest) ProtoMessage()
func (*StartWorkflowRequest) ProtoReflect ¶
func (x *StartWorkflowRequest) ProtoReflect() protoreflect.Message
func (*StartWorkflowRequest) Reset ¶
func (x *StartWorkflowRequest) Reset()
func (*StartWorkflowRequest) String ¶
func (x *StartWorkflowRequest) String() string
type StartWorkflowResponse ¶
type StartWorkflowResponse struct {
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id" json:"workflow_id,omitempty"`
// contains filtered or unexported fields
}
func (*StartWorkflowResponse) Descriptor
deprecated
func (*StartWorkflowResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartWorkflowResponse.ProtoReflect.Descriptor instead.
func (*StartWorkflowResponse) GetWorkflowId ¶
func (x *StartWorkflowResponse) GetWorkflowId() string
func (*StartWorkflowResponse) ProtoMessage ¶
func (*StartWorkflowResponse) ProtoMessage()
func (*StartWorkflowResponse) ProtoReflect ¶
func (x *StartWorkflowResponse) ProtoReflect() protoreflect.Message
func (*StartWorkflowResponse) Reset ¶
func (x *StartWorkflowResponse) Reset()
func (*StartWorkflowResponse) String ¶
func (x *StartWorkflowResponse) String() string
type UnimplementedAutoFlowServer ¶
type UnimplementedAutoFlowServer struct{}
UnimplementedAutoFlowServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAutoFlowServer) CloudEvent ¶
func (UnimplementedAutoFlowServer) CloudEvent(context.Context, *CloudEventRequest) (*CloudEventResponse, error)
func (UnimplementedAutoFlowServer) StartWorkflow ¶
func (UnimplementedAutoFlowServer) StartWorkflow(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)
type UnsafeAutoFlowServer ¶
type UnsafeAutoFlowServer interface {
// contains filtered or unexported methods
}
UnsafeAutoFlowServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AutoFlowServer will result in compilation errors.