v1

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2024 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Config_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Config",
	HandlerType: (*ConfigServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetConfig",
			Handler:    _Config_SetConfig_Handler,
		},
		{
			MethodName: "SetAdjustment",
			Handler:    _Config_SetAdjustment_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/cri/resource-manager/config/api/v1/api.proto",
}

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

View Source 
var File_pkg_cri_resource_manager_config_api_v1_api_proto protoreflect.FileDescriptor

Functions

func RegisterConfigServer 

func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)

Types

type ConfigClient 

type ConfigClient interface {
	SetConfig(ctx context.Context, in *SetConfigRequest, opts ...grpc.CallOption) (*SetConfigReply, error)
	SetAdjustment(ctx context.Context, in *SetAdjustmentRequest, opts ...grpc.CallOption) (*SetAdjustmentReply, error)
}

ConfigClient is the client API for Config 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 NewConfigClient 

func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient

type ConfigServer 

type ConfigServer interface {
	SetConfig(context.Context, *SetConfigRequest) (*SetConfigReply, error)
	SetAdjustment(context.Context, *SetAdjustmentRequest) (*SetAdjustmentReply, error)
	// contains filtered or unexported methods
}

ConfigServer is the server API for Config service. All implementations must embed UnimplementedConfigServer for forward compatibility

type SetAdjustmentReply added in v0.4.0 

type SetAdjustmentReply struct {

	// If not empty, indicates that errors happened while trying to apply the adjustments.
	Errors map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetAdjustmentReply) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use SetAdjustmentReply.ProtoReflect.Descriptor instead.

func (*SetAdjustmentReply) GetErrors added in v0.4.0 

func (x *SetAdjustmentReply) GetErrors() map[string]string

func (*SetAdjustmentReply) ProtoMessage added in v0.4.0 

func (*SetAdjustmentReply) ProtoMessage()

func (*SetAdjustmentReply) ProtoReflect added in v0.8.0 

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

func (*SetAdjustmentReply) Reset added in v0.4.0 

func (x *SetAdjustmentReply) Reset()

func (*SetAdjustmentReply) String added in v0.4.0 

func (x *SetAdjustmentReply) String() string

type SetAdjustmentRequest added in v0.4.0 

type SetAdjustmentRequest struct {

	// node_name is node name used to acquire this configuration.
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Serialized map of all adjustment CRDs, name as key, CRD as value.
	Adjustment string `protobuf:"bytes,2,opt,name=adjustment,proto3" json:"adjustment,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAdjustmentRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use SetAdjustmentRequest.ProtoReflect.Descriptor instead.

func (*SetAdjustmentRequest) GetAdjustment added in v0.4.0 

func (x *SetAdjustmentRequest) GetAdjustment() string

func (*SetAdjustmentRequest) GetNodeName added in v0.4.0 

func (x *SetAdjustmentRequest) GetNodeName() string

func (*SetAdjustmentRequest) ProtoMessage added in v0.4.0 

func (*SetAdjustmentRequest) ProtoMessage()

func (*SetAdjustmentRequest) ProtoReflect added in v0.8.0 

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

func (*SetAdjustmentRequest) Reset added in v0.4.0 

func (x *SetAdjustmentRequest) Reset()

func (*SetAdjustmentRequest) String added in v0.4.0 

func (x *SetAdjustmentRequest) String() string

type SetConfigReply 

type SetConfigReply struct {

	// If not empty, indicate an error that happened while trying to apply new configuration.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SetConfigReply) Descriptor deprecated 

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

Deprecated: Use SetConfigReply.ProtoReflect.Descriptor instead.

func (*SetConfigReply) GetError 

func (x *SetConfigReply) GetError() string

func (*SetConfigReply) ProtoMessage 

func (*SetConfigReply) ProtoMessage()

func (*SetConfigReply) ProtoReflect added in v0.8.0 

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

func (*SetConfigReply) Reset 

func (x *SetConfigReply) Reset()

func (*SetConfigReply) String 

func (x *SetConfigReply) String() string

type SetConfigRequest 

type SetConfigRequest struct {

	// node_name is node name used to acquire this configuration.
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// config is the ConfigMap data.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetConfigRequest.ProtoReflect.Descriptor instead.

func (*SetConfigRequest) GetConfig 

func (x *SetConfigRequest) GetConfig() map[string]string

func (*SetConfigRequest) GetNodeName 

func (x *SetConfigRequest) GetNodeName() string

func (*SetConfigRequest) ProtoMessage 

func (*SetConfigRequest) ProtoMessage()

func (*SetConfigRequest) ProtoReflect added in v0.8.0 

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

func (*SetConfigRequest) Reset 

func (x *SetConfigRequest) Reset()

func (*SetConfigRequest) String 

func (x *SetConfigRequest) String() string

type UnimplementedConfigServer 

type UnimplementedConfigServer struct {
}

UnimplementedConfigServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigServer) SetAdjustment added in v0.4.0 

func (UnimplementedConfigServer) SetAdjustment(context.Context, *SetAdjustmentRequest) (*SetAdjustmentReply, error)

func (UnimplementedConfigServer) SetConfig 

func (UnimplementedConfigServer) SetConfig(context.Context, *SetConfigRequest) (*SetConfigReply, error)

type UnsafeConfigServer added in v0.8.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.