replicator

Documentation

Index

• Constants
• Variables
• func RegisterReplicatorServer(s grpc.ServiceRegistrar, srv ReplicatorServer)
• type ReplicateBlobsRequest
  • func (*ReplicateBlobsRequest) Descriptor() ([]byte, []int)
  • func (x *ReplicateBlobsRequest) GetBlobDigests() []*v2.Digest
  • func (x *ReplicateBlobsRequest) GetDigestFunction() v2.DigestFunction_Value
  • func (x *ReplicateBlobsRequest) GetInstanceName() string
  • func (*ReplicateBlobsRequest) ProtoMessage()
  • func (x *ReplicateBlobsRequest) ProtoReflect() protoreflect.Message
  • func (x *ReplicateBlobsRequest) Reset()
  • func (x *ReplicateBlobsRequest) String() string
• type ReplicatorClient
  • func NewReplicatorClient(cc grpc.ClientConnInterface) ReplicatorClient
• type ReplicatorServer
• type UnimplementedReplicatorServer
  • func (UnimplementedReplicatorServer) ReplicateBlobs(context.Context, *ReplicateBlobsRequest) (*emptypb.Empty, error)
• type UnsafeReplicatorServer

Constants

const (
	Replicator_ReplicateBlobs_FullMethodName = "/buildbarn.replicator.Replicator/ReplicateBlobs"
)

Variables

var File_pkg_proto_replicator_replicator_proto protoreflect.FileDescriptor

var Replicator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buildbarn.replicator.Replicator",
	HandlerType: (*ReplicatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReplicateBlobs",
			Handler:    _Replicator_ReplicateBlobs_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/replicator/replicator.proto",
}

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

Functions

func RegisterReplicatorServer

func RegisterReplicatorServer(s grpc.ServiceRegistrar, srv ReplicatorServer)

Types

type ReplicateBlobsRequest

type ReplicateBlobsRequest struct {
	InstanceName   string                  `protobuf:"bytes,1,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	BlobDigests    []*v2.Digest            `protobuf:"bytes,2,rep,name=blob_digests,json=blobDigests,proto3" json:"blob_digests,omitempty"`
	DigestFunction v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicateBlobsRequest) Descriptor

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

Deprecated: Use ReplicateBlobsRequest.ProtoReflect.Descriptor instead.

func (*ReplicateBlobsRequest) GetBlobDigests

func (x *ReplicateBlobsRequest) GetBlobDigests() []*v2.Digest

func (*ReplicateBlobsRequest) GetDigestFunction

func (x *ReplicateBlobsRequest) GetDigestFunction() v2.DigestFunction_Value

func (*ReplicateBlobsRequest) GetInstanceName

func (x *ReplicateBlobsRequest) GetInstanceName() string

func (*ReplicateBlobsRequest) ProtoMessage

func (*ReplicateBlobsRequest) ProtoMessage()

func (*ReplicateBlobsRequest) ProtoReflect

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

func (*ReplicateBlobsRequest) Reset

func (x *ReplicateBlobsRequest) Reset()

func (*ReplicateBlobsRequest) String

func (x *ReplicateBlobsRequest) String() string

type ReplicatorClient

type ReplicatorClient interface {
	ReplicateBlobs(ctx context.Context, in *ReplicateBlobsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ReplicatorClient is the client API for Replicator 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 NewReplicatorClient

func NewReplicatorClient(cc grpc.ClientConnInterface) ReplicatorClient

type ReplicatorServer

type ReplicatorServer interface {
	ReplicateBlobs(context.Context, *ReplicateBlobsRequest) (*emptypb.Empty, error)
}

ReplicatorServer is the server API for Replicator service. All implementations should embed UnimplementedReplicatorServer for forward compatibility

type UnimplementedReplicatorServer

type UnimplementedReplicatorServer struct {
}

UnimplementedReplicatorServer should be embedded to have forward compatible implementations.

func (UnimplementedReplicatorServer) ReplicateBlobs

func (UnimplementedReplicatorServer) ReplicateBlobs(context.Context, *ReplicateBlobsRequest) (*emptypb.Empty, error)

type UnsafeReplicatorServer

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

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