pboperator

Documentation

Index

• Variables
• func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)
• func TransferLeaderResponseFromAPI(t *api.TransferLeaderResponse, s *TransferLeaderResponse)
• func TransferLeaderResponseToAPI(s *TransferLeaderResponse, t *api.TransferLeaderResponse)
• type OperatorServiceClient
  • func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient
• type OperatorServiceServer
• type TransferLeaderRequest
  • func (*TransferLeaderRequest) Descriptor() ([]byte, []int)
  • func (x *TransferLeaderRequest) GetID() string
  • func (msg *TransferLeaderRequest) MarshalBinary() ([]byte, error)
  • func (*TransferLeaderRequest) ProtoMessage()
  • func (x *TransferLeaderRequest) ProtoReflect() protoreflect.Message
  • func (x *TransferLeaderRequest) Reset()
  • func (x *TransferLeaderRequest) String() string
  • func (msg *TransferLeaderRequest) UnmarshalBinary(b []byte) error
• type TransferLeaderResponse
  • func (*TransferLeaderResponse) Descriptor() ([]byte, []int)
  • func (x *TransferLeaderResponse) GetSuccess() bool
  • func (msg *TransferLeaderResponse) MarshalBinary() ([]byte, error)
  • func (*TransferLeaderResponse) ProtoMessage()
  • func (x *TransferLeaderResponse) ProtoReflect() protoreflect.Message
  • func (x *TransferLeaderResponse) Reset()
  • func (x *TransferLeaderResponse) String() string
  • func (msg *TransferLeaderResponse) UnmarshalBinary(b []byte) error
• type UnimplementedOperatorServiceServer
  • func (UnimplementedOperatorServiceServer) TransferLeader(context.Context, *TransferLeaderRequest) (*TransferLeaderResponse, error)
• type UnsafeOperatorServiceServer

Variables

var File_proto_pboperator_operator_proto protoreflect.FileDescriptor

var OperatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "hashicorp.consul.internal.operator.OperatorService",
	HandlerType: (*OperatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TransferLeader",
			Handler:    _OperatorService_TransferLeader_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/pboperator/operator.proto",
}

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

Functions

func RegisterOperatorServiceServer

func RegisterOperatorServiceServer(s grpc.ServiceRegistrar, srv OperatorServiceServer)

func TransferLeaderResponseFromAPI

func TransferLeaderResponseFromAPI(t *api.TransferLeaderResponse, s *TransferLeaderResponse)

func TransferLeaderResponseToAPI

func TransferLeaderResponseToAPI(s *TransferLeaderResponse, t *api.TransferLeaderResponse)

Types

type OperatorServiceClient

type OperatorServiceClient interface {
	// Transfer raft leadership to another node
	TransferLeader(ctx context.Context, in *TransferLeaderRequest, opts ...grpc.CallOption) (*TransferLeaderResponse, error)
}

OperatorServiceClient is the client API for OperatorService 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 NewOperatorServiceClient

func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient

type OperatorServiceServer

type OperatorServiceServer interface {
	// Transfer raft leadership to another node
	TransferLeader(context.Context, *TransferLeaderRequest) (*TransferLeaderResponse, error)
}

OperatorServiceServer is the server API for OperatorService service. All implementations should embed UnimplementedOperatorServiceServer for forward compatibility

type TransferLeaderRequest

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

func (*TransferLeaderRequest) Descriptor

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

Deprecated: Use TransferLeaderRequest.ProtoReflect.Descriptor instead.

func (*TransferLeaderRequest) GetID

func (x *TransferLeaderRequest) GetID() string

func (*TransferLeaderRequest) MarshalBinary

func (msg *TransferLeaderRequest) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*TransferLeaderRequest) ProtoMessage

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) ProtoReflect

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

func (*TransferLeaderRequest) Reset

func (x *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) String

func (x *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) UnmarshalBinary

func (msg *TransferLeaderRequest) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TransferLeaderResponse

type TransferLeaderResponse struct {

	// true if the transfer is a success
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

mog annotation:

target=github.com/hashicorp/consul/api.TransferLeaderResponse output=operator.gen.go name=API

func (*TransferLeaderResponse) Descriptor

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

Deprecated: Use TransferLeaderResponse.ProtoReflect.Descriptor instead.

func (*TransferLeaderResponse) GetSuccess

func (x *TransferLeaderResponse) GetSuccess() bool

func (*TransferLeaderResponse) MarshalBinary

func (msg *TransferLeaderResponse) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*TransferLeaderResponse) ProtoMessage

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) ProtoReflect

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

func (*TransferLeaderResponse) Reset

func (x *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) String

func (x *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) UnmarshalBinary

func (msg *TransferLeaderResponse) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type UnimplementedOperatorServiceServer

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedOperatorServiceServer) TransferLeader

func (UnimplementedOperatorServiceServer) TransferLeader(context.Context, *TransferLeaderRequest) (*TransferLeaderResponse, error)

type UnsafeOperatorServiceServer

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

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