rpc

Documentation

Index

• Constants
• Variables
• func RegisterAutoFlowServer(s grpc.ServiceRegistrar, srv AutoFlowServer)
• type AutoFlowClient
  • func NewAutoFlowClient(cc grpc.ClientConnInterface) AutoFlowClient
• type AutoFlowServer
• type CloudEventRequest
  • func (*CloudEventRequest) Descriptor() ([]byte, []int)
  • func (x *CloudEventRequest) GetEvent() *event.CloudEvent
  • func (x *CloudEventRequest) GetFlowProject() *event.Project
  • func (*CloudEventRequest) ProtoMessage()
  • func (x *CloudEventRequest) ProtoReflect() protoreflect.Message
  • func (x *CloudEventRequest) Reset()
  • func (x *CloudEventRequest) String() string
• type CloudEventResponse
  • func (*CloudEventResponse) Descriptor() ([]byte, []int)
  • func (*CloudEventResponse) ProtoMessage()
  • func (x *CloudEventResponse) ProtoReflect() protoreflect.Message
  • func (x *CloudEventResponse) Reset()
  • func (x *CloudEventResponse) String() string
• type UnimplementedAutoFlowServer
  • func (UnimplementedAutoFlowServer) CloudEvent(context.Context, *CloudEventRequest) (*CloudEventResponse, error)
• type UnsafeAutoFlowServer

Constants

const (
	AutoFlow_CloudEvent_FullMethodName = "/gitlab.agent.autoflow.rpc.AutoFlow/CloudEvent"
)

Variables

var AutoFlow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.autoflow.rpc.AutoFlow",
	HandlerType: (*AutoFlowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CloudEvent",
			Handler:    _AutoFlow_CloudEvent_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)
}

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)
	// 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,proto3" json:"event,omitempty"`
	FlowProject *event.Project    `protobuf:"bytes,2,opt,name=flow_project,json=flowProject,proto3" json:"flow_project,omitempty"`
	// contains filtered or unexported fields
}

func (*CloudEventRequest) Descriptor

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) 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

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 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)

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.