proto

Documentation

Index

• Variables
• func RegisterReconfigureServer(s grpc.ServiceRegistrar, srv ReconfigureServer)
• type OnlineUpgradeParamsRequest
  • func (*OnlineUpgradeParamsRequest) Descriptor() ([]byte, []int)
  • func (x *OnlineUpgradeParamsRequest) GetConfigSpec() string
  • func (x *OnlineUpgradeParamsRequest) GetParams() map[string]string
  • func (*OnlineUpgradeParamsRequest) ProtoMessage()
  • func (x *OnlineUpgradeParamsRequest) ProtoReflect() protoreflect.Message
  • func (x *OnlineUpgradeParamsRequest) Reset()
  • func (x *OnlineUpgradeParamsRequest) String() string
• type OnlineUpgradeParamsResponse
  • func (*OnlineUpgradeParamsResponse) Descriptor() ([]byte, []int)
  • func (x *OnlineUpgradeParamsResponse) GetErrMessage() string
  • func (*OnlineUpgradeParamsResponse) ProtoMessage()
  • func (x *OnlineUpgradeParamsResponse) ProtoReflect() protoreflect.Message
  • func (x *OnlineUpgradeParamsResponse) Reset()
  • func (x *OnlineUpgradeParamsResponse) String() string
• type ReconfigureClient
  • func NewReconfigureClient(cc grpc.ClientConnInterface) ReconfigureClient
• type ReconfigureServer
• type StopContainerRequest
  • func (*StopContainerRequest) Descriptor() ([]byte, []int)
  • func (x *StopContainerRequest) GetContainerIDs() []string
  • func (*StopContainerRequest) ProtoMessage()
  • func (x *StopContainerRequest) ProtoReflect() protoreflect.Message
  • func (x *StopContainerRequest) Reset()
  • func (x *StopContainerRequest) String() string
• type StopContainerResponse
  • func (*StopContainerResponse) Descriptor() ([]byte, []int)
  • func (x *StopContainerResponse) GetErrMessage() string
  • func (*StopContainerResponse) ProtoMessage()
  • func (x *StopContainerResponse) ProtoReflect() protoreflect.Message
  • func (x *StopContainerResponse) Reset()
  • func (x *StopContainerResponse) String() string
• type UnimplementedReconfigureServer
  • func (UnimplementedReconfigureServer) OnlineUpgradeParams(context.Context, *OnlineUpgradeParamsRequest) (*OnlineUpgradeParamsResponse, error)
  • func (UnimplementedReconfigureServer) StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
• type UnsafeReconfigureServer

Variables

var File_reconfigure_proto protoreflect.FileDescriptor

var Reconfigure_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Reconfigure",
	HandlerType: (*ReconfigureServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StopContainer",
			Handler:    _Reconfigure_StopContainer_Handler,
		},
		{
			MethodName: "OnlineUpgradeParams",
			Handler:    _Reconfigure_OnlineUpgradeParams_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "reconfigure.proto",
}

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

Functions

func RegisterReconfigureServer

func RegisterReconfigureServer(s grpc.ServiceRegistrar, srv ReconfigureServer)

Types

type OnlineUpgradeParamsRequest

type OnlineUpgradeParamsRequest struct {
	ConfigSpec string            `protobuf:"bytes,1,opt,name=configSpec,proto3" json:"configSpec,omitempty"`
	Params     map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OnlineUpgradeParamsRequest) Descriptor

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

Deprecated: Use OnlineUpgradeParamsRequest.ProtoReflect.Descriptor instead.

func (*OnlineUpgradeParamsRequest) GetConfigSpec

func (x *OnlineUpgradeParamsRequest) GetConfigSpec() string

func (*OnlineUpgradeParamsRequest) GetParams

func (x *OnlineUpgradeParamsRequest) GetParams() map[string]string

func (*OnlineUpgradeParamsRequest) ProtoMessage

func (*OnlineUpgradeParamsRequest) ProtoMessage()

func (*OnlineUpgradeParamsRequest) ProtoReflect

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

func (*OnlineUpgradeParamsRequest) Reset

func (x *OnlineUpgradeParamsRequest) Reset()

func (*OnlineUpgradeParamsRequest) String

func (x *OnlineUpgradeParamsRequest) String() string

type OnlineUpgradeParamsResponse

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

func (*OnlineUpgradeParamsResponse) Descriptor

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

Deprecated: Use OnlineUpgradeParamsResponse.ProtoReflect.Descriptor instead.

func (*OnlineUpgradeParamsResponse) GetErrMessage

func (x *OnlineUpgradeParamsResponse) GetErrMessage() string

func (*OnlineUpgradeParamsResponse) ProtoMessage

func (*OnlineUpgradeParamsResponse) ProtoMessage()

func (*OnlineUpgradeParamsResponse) ProtoReflect

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

func (*OnlineUpgradeParamsResponse) Reset

func (x *OnlineUpgradeParamsResponse) Reset()

func (*OnlineUpgradeParamsResponse) String

func (x *OnlineUpgradeParamsResponse) String() string

type ReconfigureClient

type ReconfigureClient interface {
	StopContainer(ctx context.Context, in *StopContainerRequest, opts ...grpc.CallOption) (*StopContainerResponse, error)
	OnlineUpgradeParams(ctx context.Context, in *OnlineUpgradeParamsRequest, opts ...grpc.CallOption) (*OnlineUpgradeParamsResponse, error)
}

ReconfigureClient is the client API for Reconfigure 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 NewReconfigureClient

func NewReconfigureClient(cc grpc.ClientConnInterface) ReconfigureClient

type ReconfigureServer

type ReconfigureServer interface {
	StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
	OnlineUpgradeParams(context.Context, *OnlineUpgradeParamsRequest) (*OnlineUpgradeParamsResponse, error)
	// contains filtered or unexported methods
}

ReconfigureServer is the server API for Reconfigure service. All implementations must embed UnimplementedReconfigureServer for forward compatibility

type StopContainerRequest

type StopContainerRequest struct {
	ContainerIDs []string `protobuf:"bytes,1,rep,name=containerIDs,proto3" json:"containerIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*StopContainerRequest) Descriptor

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

Deprecated: Use StopContainerRequest.ProtoReflect.Descriptor instead.

func (*StopContainerRequest) GetContainerIDs

func (x *StopContainerRequest) GetContainerIDs() []string

func (*StopContainerRequest) ProtoMessage

func (*StopContainerRequest) ProtoMessage()

func (*StopContainerRequest) ProtoReflect

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

func (*StopContainerRequest) Reset

func (x *StopContainerRequest) Reset()

func (*StopContainerRequest) String

func (x *StopContainerRequest) String() string

type StopContainerResponse

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

func (*StopContainerResponse) Descriptor

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

Deprecated: Use StopContainerResponse.ProtoReflect.Descriptor instead.

func (*StopContainerResponse) GetErrMessage

func (x *StopContainerResponse) GetErrMessage() string

func (*StopContainerResponse) ProtoMessage

func (*StopContainerResponse) ProtoMessage()

func (*StopContainerResponse) ProtoReflect

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

func (*StopContainerResponse) Reset

func (x *StopContainerResponse) Reset()

func (*StopContainerResponse) String

func (x *StopContainerResponse) String() string

type UnimplementedReconfigureServer

type UnimplementedReconfigureServer struct {
}

UnimplementedReconfigureServer must be embedded to have forward compatible implementations.

func (UnimplementedReconfigureServer) OnlineUpgradeParams

func (UnimplementedReconfigureServer) OnlineUpgradeParams(context.Context, *OnlineUpgradeParamsRequest) (*OnlineUpgradeParamsResponse, error)

func (UnimplementedReconfigureServer) StopContainer

func (UnimplementedReconfigureServer) StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)

type UnsafeReconfigureServer

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

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