rpc

Documentation

Index

• Constants
• Variables
• func RegisterGitLabFluxServer(s grpc.ServiceRegistrar, srv GitLabFluxServer)
• type GitLabFluxClient
  • func NewGitLabFluxClient(cc grpc.ClientConnInterface) GitLabFluxClient
• type GitLabFluxServer
• type GitLabFlux_ReconcileProjectsClient
• type GitLabFlux_ReconcileProjectsServer
• type Project
  • func ReconcileProjectsFromSlice(projects []string) []*Project
  • func (*Project) Descriptor() ([]byte, []int)
  • func (x *Project) GetId() string
  • func (*Project) ProtoMessage()
  • func (x *Project) ProtoReflect() protoreflect.Message
  • func (x *Project) Reset()
  • func (x *Project) String() string
• type ReconcileProjectsRequest
  • func (*ReconcileProjectsRequest) Descriptor() ([]byte, []int)
  • func (x *ReconcileProjectsRequest) GetProject() []*Project
  • func (*ReconcileProjectsRequest) ProtoMessage()
  • func (x *ReconcileProjectsRequest) ProtoReflect() protoreflect.Message
  • func (x *ReconcileProjectsRequest) Reset()
  • func (x *ReconcileProjectsRequest) String() string
  • func (x *ReconcileProjectsRequest) ToProjectSet() map[string]struct{}
• type ReconcileProjectsResponse
  • func (*ReconcileProjectsResponse) Descriptor() ([]byte, []int)
  • func (x *ReconcileProjectsResponse) GetProject() *Project
  • func (*ReconcileProjectsResponse) ProtoMessage()
  • func (x *ReconcileProjectsResponse) ProtoReflect() protoreflect.Message
  • func (x *ReconcileProjectsResponse) Reset()
  • func (x *ReconcileProjectsResponse) String() string
• type UnimplementedGitLabFluxServer
  • func (UnimplementedGitLabFluxServer) ReconcileProjects(*ReconcileProjectsRequest, ...) error
• type UnsafeGitLabFluxServer

Constants

const (
	GitLabFlux_ReconcileProjects_FullMethodName = "/gitlab.agent.flux.rpc.GitLabFlux/ReconcileProjects"
)

Variables

var File_internal_module_flux_rpc_rpc_proto protoreflect.FileDescriptor

var GitLabFlux_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.flux.rpc.GitLabFlux",
	HandlerType: (*GitLabFluxServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReconcileProjects",
			Handler:       _GitLabFlux_ReconcileProjects_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/module/flux/rpc/rpc.proto",
}

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

Functions

func RegisterGitLabFluxServer

func RegisterGitLabFluxServer(s grpc.ServiceRegistrar, srv GitLabFluxServer)

Types

type GitLabFluxClient

type GitLabFluxClient interface {
	ReconcileProjects(ctx context.Context, in *ReconcileProjectsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReconcileProjectsResponse], error)
}

GitLabFluxClient is the client API for GitLabFlux 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 NewGitLabFluxClient

func NewGitLabFluxClient(cc grpc.ClientConnInterface) GitLabFluxClient

type GitLabFluxServer

type GitLabFluxServer interface {
	ReconcileProjects(*ReconcileProjectsRequest, grpc.ServerStreamingServer[ReconcileProjectsResponse]) error
	// contains filtered or unexported methods
}

GitLabFluxServer is the server API for GitLabFlux service. All implementations must embed UnimplementedGitLabFluxServer for forward compatibility.

type GitLabFlux_ReconcileProjectsClient

type GitLabFlux_ReconcileProjectsClient = grpc.ServerStreamingClient[ReconcileProjectsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GitLabFlux_ReconcileProjectsServer

type GitLabFlux_ReconcileProjectsServer = grpc.ServerStreamingServer[ReconcileProjectsResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Project

type Project struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func ReconcileProjectsFromSlice

func ReconcileProjectsFromSlice(projects []string) []*Project

func (*Project) Descriptor

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetId

func (x *Project) GetId() string

func (*Project) ProtoMessage

func (*Project) ProtoMessage()

func (*Project) ProtoReflect

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

func (*Project) Reset

func (x *Project) Reset()

func (*Project) String

func (x *Project) String() string

type ReconcileProjectsRequest

type ReconcileProjectsRequest struct {
	Project []*Project `protobuf:"bytes,1,rep,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ReconcileProjectsRequest) Descriptor

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

Deprecated: Use ReconcileProjectsRequest.ProtoReflect.Descriptor instead.

func (*ReconcileProjectsRequest) GetProject

func (x *ReconcileProjectsRequest) GetProject() []*Project

func (*ReconcileProjectsRequest) ProtoMessage

func (*ReconcileProjectsRequest) ProtoMessage()

func (*ReconcileProjectsRequest) ProtoReflect

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

func (*ReconcileProjectsRequest) Reset

func (x *ReconcileProjectsRequest) Reset()

func (*ReconcileProjectsRequest) String

func (x *ReconcileProjectsRequest) String() string

func (*ReconcileProjectsRequest) ToProjectSet

func (x *ReconcileProjectsRequest) ToProjectSet() map[string]struct{}

type ReconcileProjectsResponse

type ReconcileProjectsResponse struct {
	Project *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*ReconcileProjectsResponse) Descriptor

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

Deprecated: Use ReconcileProjectsResponse.ProtoReflect.Descriptor instead.

func (*ReconcileProjectsResponse) GetProject

func (x *ReconcileProjectsResponse) GetProject() *Project

func (*ReconcileProjectsResponse) ProtoMessage

func (*ReconcileProjectsResponse) ProtoMessage()

func (*ReconcileProjectsResponse) ProtoReflect

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

func (*ReconcileProjectsResponse) Reset

func (x *ReconcileProjectsResponse) Reset()

func (*ReconcileProjectsResponse) String

func (x *ReconcileProjectsResponse) String() string

type UnimplementedGitLabFluxServer

type UnimplementedGitLabFluxServer struct{}

UnimplementedGitLabFluxServer 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 (UnimplementedGitLabFluxServer) ReconcileProjects

func (UnimplementedGitLabFluxServer) ReconcileProjects(*ReconcileProjectsRequest, grpc.ServerStreamingServer[ReconcileProjectsResponse]) error

type UnsafeGitLabFluxServer

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

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