rpc

Documentation

Index

• Constants
• Variables
• func RegisterNotificationsServer(s grpc.ServiceRegistrar, srv NotificationsServer)
• type GitPushEventRequest
  • func (*GitPushEventRequest) Descriptor() ([]byte, []int)
  • func (x *GitPushEventRequest) GetEvent() *event.GitPushEvent
  • func (*GitPushEventRequest) ProtoMessage()
  • func (x *GitPushEventRequest) ProtoReflect() protoreflect.Message
  • func (x *GitPushEventRequest) Reset()
  • func (x *GitPushEventRequest) String() string
• type GitPushEventResponse
  • func (*GitPushEventResponse) Descriptor() ([]byte, []int)
  • func (*GitPushEventResponse) ProtoMessage()
  • func (x *GitPushEventResponse) ProtoReflect() protoreflect.Message
  • func (x *GitPushEventResponse) Reset()
  • func (x *GitPushEventResponse) String() string
• type NotificationsClient
  • func NewNotificationsClient(cc grpc.ClientConnInterface) NotificationsClient
• type NotificationsServer
• type UnimplementedNotificationsServer
  • func (UnimplementedNotificationsServer) GitPushEvent(context.Context, *GitPushEventRequest) (*GitPushEventResponse, error)
• type UnsafeNotificationsServer

Constants

const (
	Notifications_GitPushEvent_FullMethodName = "/gitlab.agent.notifications.rpc.Notifications/GitPushEvent"
)

Variables

var File_internal_module_notifications_rpc_rpc_proto protoreflect.FileDescriptor

var Notifications_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.notifications.rpc.Notifications",
	HandlerType: (*NotificationsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GitPushEvent",
			Handler:    _Notifications_GitPushEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/module/notifications/rpc/rpc.proto",
}

Notifications_ServiceDesc is the grpc.ServiceDesc for Notifications service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterNotificationsServer

func RegisterNotificationsServer(s grpc.ServiceRegistrar, srv NotificationsServer)

Types

type GitPushEventRequest

type GitPushEventRequest struct {
	Event *event.GitPushEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*GitPushEventRequest) Descriptor

func (*GitPushEventRequest) Descriptor() ([]byte, []int)

Deprecated: Use GitPushEventRequest.ProtoReflect.Descriptor instead.

func (*GitPushEventRequest) GetEvent

func (x *GitPushEventRequest) GetEvent() *event.GitPushEvent

func (*GitPushEventRequest) ProtoMessage

func (*GitPushEventRequest) ProtoMessage()

func (*GitPushEventRequest) ProtoReflect

func (x *GitPushEventRequest) ProtoReflect() protoreflect.Message

func (*GitPushEventRequest) Reset

func (x *GitPushEventRequest) Reset()

func (*GitPushEventRequest) String

func (x *GitPushEventRequest) String() string

type GitPushEventResponse

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

func (*GitPushEventResponse) Descriptor

func (*GitPushEventResponse) Descriptor() ([]byte, []int)

Deprecated: Use GitPushEventResponse.ProtoReflect.Descriptor instead.

func (*GitPushEventResponse) ProtoMessage

func (*GitPushEventResponse) ProtoMessage()

func (*GitPushEventResponse) ProtoReflect

func (x *GitPushEventResponse) ProtoReflect() protoreflect.Message

func (*GitPushEventResponse) Reset

func (x *GitPushEventResponse) Reset()

func (*GitPushEventResponse) String

func (x *GitPushEventResponse) String() string

type NotificationsClient

type NotificationsClient interface {
	GitPushEvent(ctx context.Context, in *GitPushEventRequest, opts ...grpc.CallOption) (*GitPushEventResponse, error)
}

NotificationsClient is the client API for Notifications 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 NewNotificationsClient

func NewNotificationsClient(cc grpc.ClientConnInterface) NotificationsClient

type NotificationsServer

type NotificationsServer interface {
	GitPushEvent(context.Context, *GitPushEventRequest) (*GitPushEventResponse, error)
	// contains filtered or unexported methods
}

NotificationsServer is the server API for Notifications service. All implementations must embed UnimplementedNotificationsServer for forward compatibility.

type UnimplementedNotificationsServer

type UnimplementedNotificationsServer struct{}

UnimplementedNotificationsServer 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 (UnimplementedNotificationsServer) GitPushEvent

func (UnimplementedNotificationsServer) GitPushEvent(context.Context, *GitPushEventRequest) (*GitPushEventResponse, error)

type UnsafeNotificationsServer

type UnsafeNotificationsServer interface {
	// contains filtered or unexported methods
}

UnsafeNotificationsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationsServer will result in compilation errors.