control

package
v0.43.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2024 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ControlService_HealthCheck_FullMethodName     = "/ircontrol.ControlService/HealthCheck"
	ControlService_TickEpoch_FullMethodName       = "/ircontrol.ControlService/TickEpoch"
	ControlService_RemoveNode_FullMethodName      = "/ircontrol.ControlService/RemoveNode"
	ControlService_RemoveContainer_FullMethodName = "/ircontrol.ControlService/RemoveContainer"
)

Variables

View Source
var (
	HealthStatus_name = map[int32]string{
		0: "HEALTH_STATUS_UNDEFINED",
		1: "STARTING",
		2: "READY",
		3: "SHUTTING_DOWN",
		4: "RECONFIGURING",
	}
	HealthStatus_value = map[string]int32{
		"HEALTH_STATUS_UNDEFINED": 0,
		"STARTING":                1,
		"READY":                   2,
		"SHUTTING_DOWN":           3,
		"RECONFIGURING":           4,
	}
)
View Source
var ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ircontrol.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HealthCheck",
			Handler:    _ControlService_HealthCheck_Handler,
		},
		{
			MethodName: "TickEpoch",
			Handler:    _ControlService_TickEpoch_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _ControlService_RemoveNode_Handler,
		},
		{
			MethodName: "RemoveContainer",
			Handler:    _ControlService_RemoveContainer_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/services/control/ir/service.proto",
}

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

Functions

func RegisterControlServiceServer

func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)

Types

type ControlServiceClient

type ControlServiceClient interface {
	// Performs health check of the IR node.
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// Forces a new epoch to be signaled by the IR node with high probability.
	TickEpoch(ctx context.Context, in *TickEpochRequest, opts ...grpc.CallOption) (*TickEpochResponse, error)
	// Forces a node removal to be signaled by the IR node with high probability.
	RemoveNode(ctx context.Context, in *RemoveNodeRequest, opts ...grpc.CallOption) (*RemoveNodeResponse, error)
	// Forces a container removal to be signaled by the IR node with high
	// probability.
	RemoveContainer(ctx context.Context, in *RemoveContainerRequest, opts ...grpc.CallOption) (*RemoveContainerResponse, error)
}

ControlServiceClient is the client API for ControlService 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.

type ControlServiceServer

type ControlServiceServer interface {
	// Performs health check of the IR node.
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// Forces a new epoch to be signaled by the IR node with high probability.
	TickEpoch(context.Context, *TickEpochRequest) (*TickEpochResponse, error)
	// Forces a node removal to be signaled by the IR node with high probability.
	RemoveNode(context.Context, *RemoveNodeRequest) (*RemoveNodeResponse, error)
	// Forces a container removal to be signaled by the IR node with high
	// probability.
	RemoveContainer(context.Context, *RemoveContainerRequest) (*RemoveContainerResponse, error)
}

ControlServiceServer is the server API for ControlService service. All implementations should embed UnimplementedControlServiceServer for forward compatibility

type HealthCheckRequest

type HealthCheckRequest struct {
	Body      *HealthCheckRequest_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func (*HealthCheckRequest) EmitProtobuf added in v0.43.0

func (x *HealthCheckRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthCheckRequest) GetBody

func (*HealthCheckRequest) GetSignature

func (x *HealthCheckRequest) GetSignature() *Signature

func (*HealthCheckRequest) MarshalEasyJSON added in v0.43.0

func (x *HealthCheckRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthCheckRequest) MarshalJSON added in v0.43.0

func (x *HealthCheckRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthCheckRequest) MarshalProtobuf added in v0.43.0

func (x *HealthCheckRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*HealthCheckRequest) ReadSignedData

func (x *HealthCheckRequest) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*HealthCheckRequest) SetBody

func (*HealthCheckRequest) SetSignature

func (x *HealthCheckRequest) SetSignature(v *Signature)

func (*HealthCheckRequest) SignedDataSize

func (x *HealthCheckRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*HealthCheckRequest) StableSize

func (x *HealthCheckRequest) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthCheckRequest) UnmarshalEasyJSON added in v0.43.0

func (x *HealthCheckRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthCheckRequest) UnmarshalJSON added in v0.43.0

func (x *HealthCheckRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthCheckRequest) UnmarshalProtobuf added in v0.43.0

func (x *HealthCheckRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthCheckRequest_Body

type HealthCheckRequest_Body struct {
}

func (*HealthCheckRequest_Body) EmitProtobuf added in v0.43.0

func (x *HealthCheckRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthCheckRequest_Body) MarshalEasyJSON added in v0.43.0

func (x *HealthCheckRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthCheckRequest_Body) MarshalJSON added in v0.43.0

func (x *HealthCheckRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthCheckRequest_Body) MarshalProtobuf added in v0.43.0

func (x *HealthCheckRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*HealthCheckRequest_Body) StableSize

func (x *HealthCheckRequest_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthCheckRequest_Body) UnmarshalEasyJSON added in v0.43.0

func (x *HealthCheckRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthCheckRequest_Body) UnmarshalJSON added in v0.43.0

func (x *HealthCheckRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthCheckRequest_Body) UnmarshalProtobuf added in v0.43.0

func (x *HealthCheckRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthCheckResponse

type HealthCheckResponse struct {
	Body      *HealthCheckResponse_Body `json:"body"`
	Signature *Signature                `json:"signature"`
}

func HealthCheck

func HealthCheck(
	cli *client.Client,
	req *HealthCheckRequest,
	opts ...client.CallOption,
) (*HealthCheckResponse, error)

HealthCheck executes ControlService.HealthCheck RPC.

func (*HealthCheckResponse) EmitProtobuf added in v0.43.0

func (x *HealthCheckResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*HealthCheckResponse) GetBody

func (*HealthCheckResponse) GetSignature

func (x *HealthCheckResponse) GetSignature() *Signature

func (*HealthCheckResponse) MarshalEasyJSON added in v0.43.0

func (x *HealthCheckResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthCheckResponse) MarshalJSON added in v0.43.0

func (x *HealthCheckResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthCheckResponse) MarshalProtobuf added in v0.43.0

func (x *HealthCheckResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*HealthCheckResponse) ReadSignedData

func (x *HealthCheckResponse) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*HealthCheckResponse) SetBody

func (*HealthCheckResponse) SetSignature

func (x *HealthCheckResponse) SetSignature(v *Signature)

func (*HealthCheckResponse) SignedDataSize

func (x *HealthCheckResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*HealthCheckResponse) StableSize

func (x *HealthCheckResponse) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthCheckResponse) UnmarshalEasyJSON added in v0.43.0

func (x *HealthCheckResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthCheckResponse) UnmarshalJSON added in v0.43.0

func (x *HealthCheckResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthCheckResponse) UnmarshalProtobuf added in v0.43.0

func (x *HealthCheckResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthCheckResponse_Body

type HealthCheckResponse_Body struct {
	HealthStatus HealthStatus `json:"healthStatus"`
}

func (*HealthCheckResponse_Body) EmitProtobuf added in v0.43.0

func (*HealthCheckResponse_Body) GetHealthStatus

func (x *HealthCheckResponse_Body) GetHealthStatus() HealthStatus

func (*HealthCheckResponse_Body) MarshalEasyJSON added in v0.43.0

func (x *HealthCheckResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*HealthCheckResponse_Body) MarshalJSON added in v0.43.0

func (x *HealthCheckResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*HealthCheckResponse_Body) MarshalProtobuf added in v0.43.0

func (x *HealthCheckResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*HealthCheckResponse_Body) SetHealthStatus

func (x *HealthCheckResponse_Body) SetHealthStatus(v HealthStatus)

func (*HealthCheckResponse_Body) StableSize

func (x *HealthCheckResponse_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*HealthCheckResponse_Body) UnmarshalEasyJSON added in v0.43.0

func (x *HealthCheckResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*HealthCheckResponse_Body) UnmarshalJSON added in v0.43.0

func (x *HealthCheckResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*HealthCheckResponse_Body) UnmarshalProtobuf added in v0.43.0

func (x *HealthCheckResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type HealthStatus

type HealthStatus int32
const (
	HealthStatus_HEALTH_STATUS_UNDEFINED HealthStatus = 0
	HealthStatus_STARTING                HealthStatus = 1
	HealthStatus_READY                   HealthStatus = 2
	HealthStatus_SHUTTING_DOWN           HealthStatus = 3
	HealthStatus_RECONFIGURING           HealthStatus = 4
)

func (*HealthStatus) FromString added in v0.43.0

func (x *HealthStatus) FromString(s string) bool

func (HealthStatus) String

func (x HealthStatus) String() string

type RemoveContainerRequest added in v0.37.0

type RemoveContainerRequest struct {
	Body      *RemoveContainerRequest_Body `json:"body"`
	Signature *Signature                   `json:"signature"`
}

func (*RemoveContainerRequest) EmitProtobuf added in v0.43.0

func (x *RemoveContainerRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveContainerRequest) GetBody added in v0.37.0

func (*RemoveContainerRequest) GetSignature added in v0.37.0

func (x *RemoveContainerRequest) GetSignature() *Signature

func (*RemoveContainerRequest) MarshalEasyJSON added in v0.43.0

func (x *RemoveContainerRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveContainerRequest) MarshalJSON added in v0.43.0

func (x *RemoveContainerRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveContainerRequest) MarshalProtobuf added in v0.43.0

func (x *RemoveContainerRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveContainerRequest) ReadSignedData added in v0.37.0

func (x *RemoveContainerRequest) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveContainerRequest) SetBody added in v0.43.0

func (*RemoveContainerRequest) SetSignature added in v0.37.0

func (x *RemoveContainerRequest) SetSignature(v *Signature)

func (*RemoveContainerRequest) SignedDataSize added in v0.37.0

func (x *RemoveContainerRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveContainerRequest) StableSize added in v0.37.0

func (x *RemoveContainerRequest) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveContainerRequest) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveContainerRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveContainerRequest) UnmarshalJSON added in v0.43.0

func (x *RemoveContainerRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveContainerRequest) UnmarshalProtobuf added in v0.43.0

func (x *RemoveContainerRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveContainerRequest_Body added in v0.37.0

type RemoveContainerRequest_Body struct {
	ContainerId []byte `json:"containerId"`
	Owner       []byte `json:"owner"`
	Vub         uint32 `json:"vub"`
}

func (*RemoveContainerRequest_Body) EmitProtobuf added in v0.43.0

func (*RemoveContainerRequest_Body) GetContainerId added in v0.37.0

func (x *RemoveContainerRequest_Body) GetContainerId() []byte

func (*RemoveContainerRequest_Body) GetOwner added in v0.37.0

func (x *RemoveContainerRequest_Body) GetOwner() []byte

func (*RemoveContainerRequest_Body) GetVub added in v0.38.0

func (x *RemoveContainerRequest_Body) GetVub() uint32

func (*RemoveContainerRequest_Body) MarshalEasyJSON added in v0.43.0

func (x *RemoveContainerRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveContainerRequest_Body) MarshalJSON added in v0.43.0

func (x *RemoveContainerRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveContainerRequest_Body) MarshalProtobuf added in v0.43.0

func (x *RemoveContainerRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveContainerRequest_Body) SetContainerId added in v0.43.0

func (x *RemoveContainerRequest_Body) SetContainerId(v []byte)

func (*RemoveContainerRequest_Body) SetOwner added in v0.43.0

func (x *RemoveContainerRequest_Body) SetOwner(v []byte)

func (*RemoveContainerRequest_Body) SetVub added in v0.43.0

func (x *RemoveContainerRequest_Body) SetVub(v uint32)

func (*RemoveContainerRequest_Body) StableSize added in v0.37.0

func (x *RemoveContainerRequest_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveContainerRequest_Body) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveContainerRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveContainerRequest_Body) UnmarshalJSON added in v0.43.0

func (x *RemoveContainerRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveContainerRequest_Body) UnmarshalProtobuf added in v0.43.0

func (x *RemoveContainerRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveContainerResponse added in v0.37.0

type RemoveContainerResponse struct {
	Body      *RemoveContainerResponse_Body `json:"body"`
	Signature *Signature                    `json:"signature"`
}

func RemoveContainer added in v0.37.0

func RemoveContainer(
	cli *client.Client,
	req *RemoveContainerRequest,
	opts ...client.CallOption,
) (*RemoveContainerResponse, error)

func (*RemoveContainerResponse) EmitProtobuf added in v0.43.0

func (x *RemoveContainerResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveContainerResponse) GetBody added in v0.37.0

func (*RemoveContainerResponse) GetSignature added in v0.37.0

func (x *RemoveContainerResponse) GetSignature() *Signature

func (*RemoveContainerResponse) MarshalEasyJSON added in v0.43.0

func (x *RemoveContainerResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveContainerResponse) MarshalJSON added in v0.43.0

func (x *RemoveContainerResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveContainerResponse) MarshalProtobuf added in v0.43.0

func (x *RemoveContainerResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveContainerResponse) ReadSignedData added in v0.37.0

func (x *RemoveContainerResponse) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveContainerResponse) SetBody added in v0.43.0

func (*RemoveContainerResponse) SetSignature added in v0.37.0

func (x *RemoveContainerResponse) SetSignature(v *Signature)

func (*RemoveContainerResponse) SignedDataSize added in v0.37.0

func (x *RemoveContainerResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveContainerResponse) StableSize added in v0.37.0

func (x *RemoveContainerResponse) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveContainerResponse) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveContainerResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveContainerResponse) UnmarshalJSON added in v0.43.0

func (x *RemoveContainerResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveContainerResponse) UnmarshalProtobuf added in v0.43.0

func (x *RemoveContainerResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveContainerResponse_Body added in v0.37.0

type RemoveContainerResponse_Body struct {
	Vub uint32 `json:"vub"`
}

func (*RemoveContainerResponse_Body) EmitProtobuf added in v0.43.0

func (*RemoveContainerResponse_Body) GetVub added in v0.38.0

func (*RemoveContainerResponse_Body) MarshalEasyJSON added in v0.43.0

func (x *RemoveContainerResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveContainerResponse_Body) MarshalJSON added in v0.43.0

func (x *RemoveContainerResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveContainerResponse_Body) MarshalProtobuf added in v0.43.0

func (x *RemoveContainerResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveContainerResponse_Body) SetVub added in v0.43.0

func (x *RemoveContainerResponse_Body) SetVub(v uint32)

func (*RemoveContainerResponse_Body) StableSize added in v0.37.0

func (x *RemoveContainerResponse_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveContainerResponse_Body) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveContainerResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveContainerResponse_Body) UnmarshalJSON added in v0.43.0

func (x *RemoveContainerResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveContainerResponse_Body) UnmarshalProtobuf added in v0.43.0

func (x *RemoveContainerResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveNodeRequest added in v0.37.0

type RemoveNodeRequest struct {
	Body      *RemoveNodeRequest_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func (*RemoveNodeRequest) EmitProtobuf added in v0.43.0

func (x *RemoveNodeRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveNodeRequest) GetBody added in v0.37.0

func (*RemoveNodeRequest) GetSignature added in v0.37.0

func (x *RemoveNodeRequest) GetSignature() *Signature

func (*RemoveNodeRequest) MarshalEasyJSON added in v0.43.0

func (x *RemoveNodeRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveNodeRequest) MarshalJSON added in v0.43.0

func (x *RemoveNodeRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveNodeRequest) MarshalProtobuf added in v0.43.0

func (x *RemoveNodeRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveNodeRequest) ReadSignedData added in v0.37.0

func (x *RemoveNodeRequest) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveNodeRequest) SetBody added in v0.37.0

func (*RemoveNodeRequest) SetSignature added in v0.37.0

func (x *RemoveNodeRequest) SetSignature(v *Signature)

func (*RemoveNodeRequest) SignedDataSize added in v0.37.0

func (x *RemoveNodeRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveNodeRequest) StableSize added in v0.37.0

func (x *RemoveNodeRequest) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveNodeRequest) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveNodeRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveNodeRequest) UnmarshalJSON added in v0.43.0

func (x *RemoveNodeRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveNodeRequest) UnmarshalProtobuf added in v0.43.0

func (x *RemoveNodeRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveNodeRequest_Body added in v0.37.0

type RemoveNodeRequest_Body struct {
	Key []byte `json:"key"`
	Vub uint32 `json:"vub"`
}

func (*RemoveNodeRequest_Body) EmitProtobuf added in v0.43.0

func (x *RemoveNodeRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveNodeRequest_Body) GetKey added in v0.37.0

func (x *RemoveNodeRequest_Body) GetKey() []byte

func (*RemoveNodeRequest_Body) GetVub added in v0.38.0

func (x *RemoveNodeRequest_Body) GetVub() uint32

func (*RemoveNodeRequest_Body) MarshalEasyJSON added in v0.43.0

func (x *RemoveNodeRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveNodeRequest_Body) MarshalJSON added in v0.43.0

func (x *RemoveNodeRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveNodeRequest_Body) MarshalProtobuf added in v0.43.0

func (x *RemoveNodeRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveNodeRequest_Body) SetKey added in v0.43.0

func (x *RemoveNodeRequest_Body) SetKey(v []byte)

func (*RemoveNodeRequest_Body) SetVub added in v0.43.0

func (x *RemoveNodeRequest_Body) SetVub(v uint32)

func (*RemoveNodeRequest_Body) StableSize added in v0.37.0

func (x *RemoveNodeRequest_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveNodeRequest_Body) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveNodeRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveNodeRequest_Body) UnmarshalJSON added in v0.43.0

func (x *RemoveNodeRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveNodeRequest_Body) UnmarshalProtobuf added in v0.43.0

func (x *RemoveNodeRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveNodeResponse added in v0.37.0

type RemoveNodeResponse struct {
	Body      *RemoveNodeResponse_Body `json:"body"`
	Signature *Signature               `json:"signature"`
}

func RemoveNode added in v0.37.0

func RemoveNode(
	cli *client.Client,
	req *RemoveNodeRequest,
	opts ...client.CallOption,
) (*RemoveNodeResponse, error)

func (*RemoveNodeResponse) EmitProtobuf added in v0.43.0

func (x *RemoveNodeResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveNodeResponse) GetBody added in v0.37.0

func (*RemoveNodeResponse) GetSignature added in v0.37.0

func (x *RemoveNodeResponse) GetSignature() *Signature

func (*RemoveNodeResponse) MarshalEasyJSON added in v0.43.0

func (x *RemoveNodeResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveNodeResponse) MarshalJSON added in v0.43.0

func (x *RemoveNodeResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveNodeResponse) MarshalProtobuf added in v0.43.0

func (x *RemoveNodeResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveNodeResponse) ReadSignedData added in v0.37.0

func (x *RemoveNodeResponse) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*RemoveNodeResponse) SetBody added in v0.37.0

func (*RemoveNodeResponse) SetSignature added in v0.37.0

func (x *RemoveNodeResponse) SetSignature(v *Signature)

func (*RemoveNodeResponse) SignedDataSize added in v0.37.0

func (x *RemoveNodeResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*RemoveNodeResponse) StableSize added in v0.37.0

func (x *RemoveNodeResponse) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveNodeResponse) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveNodeResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveNodeResponse) UnmarshalJSON added in v0.43.0

func (x *RemoveNodeResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveNodeResponse) UnmarshalProtobuf added in v0.43.0

func (x *RemoveNodeResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type RemoveNodeResponse_Body added in v0.37.0

type RemoveNodeResponse_Body struct {
	Vub uint32 `json:"vub"`
}

func (*RemoveNodeResponse_Body) EmitProtobuf added in v0.43.0

func (x *RemoveNodeResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*RemoveNodeResponse_Body) GetVub added in v0.38.0

func (x *RemoveNodeResponse_Body) GetVub() uint32

func (*RemoveNodeResponse_Body) MarshalEasyJSON added in v0.43.0

func (x *RemoveNodeResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*RemoveNodeResponse_Body) MarshalJSON added in v0.43.0

func (x *RemoveNodeResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*RemoveNodeResponse_Body) MarshalProtobuf added in v0.43.0

func (x *RemoveNodeResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*RemoveNodeResponse_Body) SetVub added in v0.43.0

func (x *RemoveNodeResponse_Body) SetVub(v uint32)

func (*RemoveNodeResponse_Body) StableSize added in v0.37.0

func (x *RemoveNodeResponse_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*RemoveNodeResponse_Body) UnmarshalEasyJSON added in v0.43.0

func (x *RemoveNodeResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*RemoveNodeResponse_Body) UnmarshalJSON added in v0.43.0

func (x *RemoveNodeResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*RemoveNodeResponse_Body) UnmarshalProtobuf added in v0.43.0

func (x *RemoveNodeResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type Signature

type Signature struct {
	Key  []byte `json:"key"`
	Sign []byte `json:"signature"`
}

func (*Signature) EmitProtobuf added in v0.43.0

func (x *Signature) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*Signature) GetKey

func (x *Signature) GetKey() []byte

func (*Signature) GetSign

func (x *Signature) GetSign() []byte

func (*Signature) MarshalEasyJSON added in v0.43.0

func (x *Signature) MarshalEasyJSON(out *jwriter.Writer)

func (*Signature) MarshalJSON added in v0.43.0

func (x *Signature) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*Signature) MarshalProtobuf added in v0.43.0

func (x *Signature) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*Signature) SetKey

func (x *Signature) SetKey(v []byte)

func (*Signature) SetSign

func (x *Signature) SetSign(v []byte)

func (*Signature) StableSize

func (x *Signature) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*Signature) UnmarshalEasyJSON added in v0.43.0

func (x *Signature) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*Signature) UnmarshalJSON added in v0.43.0

func (x *Signature) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*Signature) UnmarshalProtobuf added in v0.43.0

func (x *Signature) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TickEpochRequest added in v0.37.0

type TickEpochRequest struct {
	Body      *TickEpochRequest_Body `json:"body"`
	Signature *Signature             `json:"signature"`
}

func (*TickEpochRequest) EmitProtobuf added in v0.43.0

func (x *TickEpochRequest) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TickEpochRequest) GetBody added in v0.37.0

func (*TickEpochRequest) GetSignature added in v0.37.0

func (x *TickEpochRequest) GetSignature() *Signature

func (*TickEpochRequest) MarshalEasyJSON added in v0.43.0

func (x *TickEpochRequest) MarshalEasyJSON(out *jwriter.Writer)

func (*TickEpochRequest) MarshalJSON added in v0.43.0

func (x *TickEpochRequest) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TickEpochRequest) MarshalProtobuf added in v0.43.0

func (x *TickEpochRequest) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TickEpochRequest) ReadSignedData added in v0.37.0

func (x *TickEpochRequest) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*TickEpochRequest) SetBody added in v0.37.0

func (x *TickEpochRequest) SetBody(v *TickEpochRequest_Body)

func (*TickEpochRequest) SetSignature added in v0.37.0

func (x *TickEpochRequest) SetSignature(v *Signature)

func (*TickEpochRequest) SignedDataSize added in v0.37.0

func (x *TickEpochRequest) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*TickEpochRequest) StableSize added in v0.37.0

func (x *TickEpochRequest) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TickEpochRequest) UnmarshalEasyJSON added in v0.43.0

func (x *TickEpochRequest) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TickEpochRequest) UnmarshalJSON added in v0.43.0

func (x *TickEpochRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TickEpochRequest) UnmarshalProtobuf added in v0.43.0

func (x *TickEpochRequest) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TickEpochRequest_Body added in v0.37.0

type TickEpochRequest_Body struct {
	Vub uint32 `json:"vub"`
}

func (*TickEpochRequest_Body) EmitProtobuf added in v0.43.0

func (x *TickEpochRequest_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TickEpochRequest_Body) GetVub added in v0.38.0

func (x *TickEpochRequest_Body) GetVub() uint32

func (*TickEpochRequest_Body) MarshalEasyJSON added in v0.43.0

func (x *TickEpochRequest_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*TickEpochRequest_Body) MarshalJSON added in v0.43.0

func (x *TickEpochRequest_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TickEpochRequest_Body) MarshalProtobuf added in v0.43.0

func (x *TickEpochRequest_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TickEpochRequest_Body) SetVub added in v0.43.0

func (x *TickEpochRequest_Body) SetVub(v uint32)

func (*TickEpochRequest_Body) StableSize added in v0.37.0

func (x *TickEpochRequest_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TickEpochRequest_Body) UnmarshalEasyJSON added in v0.43.0

func (x *TickEpochRequest_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TickEpochRequest_Body) UnmarshalJSON added in v0.43.0

func (x *TickEpochRequest_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TickEpochRequest_Body) UnmarshalProtobuf added in v0.43.0

func (x *TickEpochRequest_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TickEpochResponse added in v0.37.0

type TickEpochResponse struct {
	Body      *TickEpochResponse_Body `json:"body"`
	Signature *Signature              `json:"signature"`
}

func TickEpoch added in v0.37.0

func TickEpoch(
	cli *client.Client,
	req *TickEpochRequest,
	opts ...client.CallOption,
) (*TickEpochResponse, error)

TickEpoch executes ControlService.TickEpoch RPC.

func (*TickEpochResponse) EmitProtobuf added in v0.43.0

func (x *TickEpochResponse) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TickEpochResponse) GetBody added in v0.37.0

func (*TickEpochResponse) GetSignature added in v0.37.0

func (x *TickEpochResponse) GetSignature() *Signature

func (*TickEpochResponse) MarshalEasyJSON added in v0.43.0

func (x *TickEpochResponse) MarshalEasyJSON(out *jwriter.Writer)

func (*TickEpochResponse) MarshalJSON added in v0.43.0

func (x *TickEpochResponse) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TickEpochResponse) MarshalProtobuf added in v0.43.0

func (x *TickEpochResponse) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TickEpochResponse) ReadSignedData added in v0.37.0

func (x *TickEpochResponse) ReadSignedData(buf []byte) ([]byte, error)

SignedDataSize returns size of the request signed data in bytes.

Structures with the same field values have the same signed data size.

func (*TickEpochResponse) SetBody added in v0.37.0

func (*TickEpochResponse) SetSignature added in v0.37.0

func (x *TickEpochResponse) SetSignature(v *Signature)

func (*TickEpochResponse) SignedDataSize added in v0.37.0

func (x *TickEpochResponse) SignedDataSize() int

ReadSignedData fills buf with signed data of x. If buffer length is less than x.SignedDataSize(), new buffer is allocated.

Returns any error encountered which did not allow writing the data completely. Otherwise, returns the buffer in which the data is written.

Structures with the same field values have the same signed data.

func (*TickEpochResponse) StableSize added in v0.37.0

func (x *TickEpochResponse) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TickEpochResponse) UnmarshalEasyJSON added in v0.43.0

func (x *TickEpochResponse) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TickEpochResponse) UnmarshalJSON added in v0.43.0

func (x *TickEpochResponse) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TickEpochResponse) UnmarshalProtobuf added in v0.43.0

func (x *TickEpochResponse) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type TickEpochResponse_Body added in v0.37.0

type TickEpochResponse_Body struct {
	Vub uint32 `json:"vub"`
}

func (*TickEpochResponse_Body) EmitProtobuf added in v0.43.0

func (x *TickEpochResponse_Body) EmitProtobuf(mm *easyproto.MessageMarshaler)

func (*TickEpochResponse_Body) GetVub added in v0.38.0

func (x *TickEpochResponse_Body) GetVub() uint32

func (*TickEpochResponse_Body) MarshalEasyJSON added in v0.43.0

func (x *TickEpochResponse_Body) MarshalEasyJSON(out *jwriter.Writer)

func (*TickEpochResponse_Body) MarshalJSON added in v0.43.0

func (x *TickEpochResponse_Body) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface.

func (*TickEpochResponse_Body) MarshalProtobuf added in v0.43.0

func (x *TickEpochResponse_Body) MarshalProtobuf(dst []byte) []byte

MarshalProtobuf implements the encoding.ProtoMarshaler interface.

func (*TickEpochResponse_Body) SetVub added in v0.43.0

func (x *TickEpochResponse_Body) SetVub(v uint32)

func (*TickEpochResponse_Body) StableSize added in v0.37.0

func (x *TickEpochResponse_Body) StableSize() (size int)

StableSize returns the size of x in protobuf format.

Structures with the same field values have the same binary size.

func (*TickEpochResponse_Body) UnmarshalEasyJSON added in v0.43.0

func (x *TickEpochResponse_Body) UnmarshalEasyJSON(in *jlexer.Lexer)

func (*TickEpochResponse_Body) UnmarshalJSON added in v0.43.0

func (x *TickEpochResponse_Body) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface.

func (*TickEpochResponse_Body) UnmarshalProtobuf added in v0.43.0

func (x *TickEpochResponse_Body) UnmarshalProtobuf(src []byte) (err error)

UnmarshalProtobuf implements the encoding.ProtoUnmarshaler interface.

type UnimplementedControlServiceServer

type UnimplementedControlServiceServer struct {
}

UnimplementedControlServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedControlServiceServer) HealthCheck

func (UnimplementedControlServiceServer) RemoveContainer added in v0.37.0

func (UnimplementedControlServiceServer) RemoveNode added in v0.37.0

func (UnimplementedControlServiceServer) TickEpoch added in v0.37.0

type UnsafeControlServiceServer

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL