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: 9 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	// ConfigStatus queries the status of the last configuration push to resmgr.
	ConfigStatus = "config-status"
)

Variables

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNode",
			Handler:    _Agent_GetNode_Handler,
		},
		{
			MethodName: "PatchNode",
			Handler:    _Agent_PatchNode_Handler,
		},
		{
			MethodName: "UpdateNodeCapacity",
			Handler:    _Agent_UpdateNodeCapacity_Handler,
		},
		{
			MethodName: "HealthCheck",
			Handler:    _Agent_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/agent/api/v1/api.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent 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_agent_api_v1_api_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

Types

type AgentClient 

type AgentClient interface {
	GetNode(ctx context.Context, in *GetNodeRequest, opts ...grpc.CallOption) (*GetNodeReply, error)
	PatchNode(ctx context.Context, in *PatchNodeRequest, opts ...grpc.CallOption) (*PatchNodeReply, error)
	UpdateNodeCapacity(ctx context.Context, in *UpdateNodeCapacityRequest, opts ...grpc.CallOption) (*UpdateNodeCapacityReply, error)
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckReply, error)
}

AgentClient is the client API for Agent 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 NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

type AgentServer interface {
	GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)
	PatchNode(context.Context, *PatchNodeRequest) (*PatchNodeReply, error)
	UpdateNodeCapacity(context.Context, *UpdateNodeCapacityRequest) (*UpdateNodeCapacityReply, error)
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckReply, error)
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type GetNodeReply 

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

func (*GetNodeReply) Descriptor deprecated 

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

Deprecated: Use GetNodeReply.ProtoReflect.Descriptor instead.

func (*GetNodeReply) GetNode 

func (x *GetNodeReply) GetNode() string

func (*GetNodeReply) ProtoMessage 

func (*GetNodeReply) ProtoMessage()

func (*GetNodeReply) ProtoReflect added in v0.8.0 

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

func (*GetNodeReply) Reset 

func (x *GetNodeReply) Reset()

func (*GetNodeReply) String 

func (x *GetNodeReply) String() string

type GetNodeRequest 

type GetNodeRequest struct {
	// contains filtered or unexported fields
}

func (*GetNodeRequest) Descriptor deprecated 

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

Deprecated: Use GetNodeRequest.ProtoReflect.Descriptor instead.

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) ProtoReflect added in v0.8.0 

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

func (*GetNodeRequest) Reset 

func (x *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (x *GetNodeRequest) String() string

type HealthCheckReply 

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

func (*HealthCheckReply) Descriptor deprecated 

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

Deprecated: Use HealthCheckReply.ProtoReflect.Descriptor instead.

func (*HealthCheckReply) GetError 

func (x *HealthCheckReply) GetError() string

func (*HealthCheckReply) ProtoMessage 

func (*HealthCheckReply) ProtoMessage()

func (*HealthCheckReply) ProtoReflect added in v0.8.0 

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

func (*HealthCheckReply) Reset 

func (x *HealthCheckReply) Reset()

func (*HealthCheckReply) String 

func (x *HealthCheckReply) String() string

type HealthCheckRequest 

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

func (*HealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use HealthCheckRequest.ProtoReflect.Descriptor instead.

func (*HealthCheckRequest) GetQuery added in v0.8.2 

func (x *HealthCheckRequest) GetQuery() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) ProtoReflect added in v0.8.0 

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

func (*HealthCheckRequest) Reset 

func (x *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (x *HealthCheckRequest) String() string

type JsonPatch 

type JsonPatch struct {
	Op    string `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"`
	Path  string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

JsonPatch holds on JSON patch

func (*JsonPatch) Descriptor deprecated 

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

Deprecated: Use JsonPatch.ProtoReflect.Descriptor instead.

func (*JsonPatch) GetOp 

func (x *JsonPatch) GetOp() string

func (*JsonPatch) GetPath 

func (x *JsonPatch) GetPath() string

func (*JsonPatch) GetValue 

func (x *JsonPatch) GetValue() string

func (*JsonPatch) MarshalJSON 

func (j *JsonPatch) MarshalJSON() ([]byte, error)

MarshalJSON marshals JsonPatch to valid Json

func (*JsonPatch) ProtoMessage 

func (*JsonPatch) ProtoMessage()

func (*JsonPatch) ProtoReflect added in v0.8.0 

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

func (*JsonPatch) Reset 

func (x *JsonPatch) Reset()

func (*JsonPatch) String 

func (x *JsonPatch) String() string

type PatchNodeReply 

type PatchNodeReply struct {
	// contains filtered or unexported fields
}

func (*PatchNodeReply) Descriptor deprecated 

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

Deprecated: Use PatchNodeReply.ProtoReflect.Descriptor instead.

func (*PatchNodeReply) ProtoMessage 

func (*PatchNodeReply) ProtoMessage()

func (*PatchNodeReply) ProtoReflect added in v0.8.0 

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

func (*PatchNodeReply) Reset 

func (x *PatchNodeReply) Reset()

func (*PatchNodeReply) String 

func (x *PatchNodeReply) String() string

type PatchNodeRequest 

type PatchNodeRequest struct {

	// List of JSON patches to apply on the node
	Patches []*JsonPatch `protobuf:"bytes,1,rep,name=patches,proto3" json:"patches,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchNodeRequest) Descriptor deprecated 

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

Deprecated: Use PatchNodeRequest.ProtoReflect.Descriptor instead.

func (*PatchNodeRequest) GetPatches 

func (x *PatchNodeRequest) GetPatches() []*JsonPatch

func (*PatchNodeRequest) ProtoMessage 

func (*PatchNodeRequest) ProtoMessage()

func (*PatchNodeRequest) ProtoReflect added in v0.8.0 

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

func (*PatchNodeRequest) Reset 

func (x *PatchNodeRequest) Reset()

func (*PatchNodeRequest) String 

func (x *PatchNodeRequest) String() string

type UnimplementedAgentServer added in v0.8.0 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) GetNode added in v0.8.0 

func (UnimplementedAgentServer) GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)

func (UnimplementedAgentServer) HealthCheck added in v0.8.0 

func (UnimplementedAgentServer) HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckReply, error)

func (UnimplementedAgentServer) PatchNode added in v0.8.0 

func (UnimplementedAgentServer) PatchNode(context.Context, *PatchNodeRequest) (*PatchNodeReply, error)

func (UnimplementedAgentServer) UpdateNodeCapacity added in v0.8.0 

func (UnimplementedAgentServer) UpdateNodeCapacity(context.Context, *UpdateNodeCapacityRequest) (*UpdateNodeCapacityReply, error)

type UnsafeAgentServer added in v0.8.0 

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

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

type UpdateNodeCapacityReply 

type UpdateNodeCapacityReply struct {
	// contains filtered or unexported fields
}

func (*UpdateNodeCapacityReply) Descriptor deprecated 

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

Deprecated: Use UpdateNodeCapacityReply.ProtoReflect.Descriptor instead.

func (*UpdateNodeCapacityReply) ProtoMessage 

func (*UpdateNodeCapacityReply) ProtoMessage()

func (*UpdateNodeCapacityReply) ProtoReflect added in v0.8.0 

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

func (*UpdateNodeCapacityReply) Reset 

func (x *UpdateNodeCapacityReply) Reset()

func (*UpdateNodeCapacityReply) String 

func (x *UpdateNodeCapacityReply) String() string

type UpdateNodeCapacityRequest 

type UpdateNodeCapacityRequest struct {

	// Name-value map of status.capacity to update
	Capacities map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateNodeCapacityRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNodeCapacityRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeCapacityRequest) GetCapacities 

func (x *UpdateNodeCapacityRequest) GetCapacities() map[string]string

func (*UpdateNodeCapacityRequest) ProtoMessage 

func (*UpdateNodeCapacityRequest) ProtoMessage()

func (*UpdateNodeCapacityRequest) ProtoReflect added in v0.8.0 

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

func (*UpdateNodeCapacityRequest) Reset 

func (x *UpdateNodeCapacityRequest) Reset()

func (*UpdateNodeCapacityRequest) String 

func (x *UpdateNodeCapacityRequest) String() string

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.