v1

package
v0.7.1 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2022 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, 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)
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigReply, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc *grpc.ClientConn) AgentClient

type AgentServer 

type AgentServer interface {
	GetNode(context.Context, *GetNodeRequest) (*GetNodeReply, error)
	PatchNode(context.Context, *PatchNodeRequest) (*PatchNodeReply, error)
	UpdateNodeCapacity(context.Context, *UpdateNodeCapacityRequest) (*UpdateNodeCapacityReply, error)
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigReply, error)
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckReply, error)
}

AgentServer is the server API for Agent service.

type GetConfigReply 

type GetConfigReply struct {
	NodeName             string            `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Config               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetConfigReply) Descriptor 

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

func (*GetConfigReply) GetConfig 

func (m *GetConfigReply) GetConfig() map[string]string

func (*GetConfigReply) GetNodeName 

func (m *GetConfigReply) GetNodeName() string

func (*GetConfigReply) ProtoMessage 

func (*GetConfigReply) ProtoMessage()

func (*GetConfigReply) Reset 

func (m *GetConfigReply) Reset()

func (*GetConfigReply) String 

func (m *GetConfigReply) String() string

func (*GetConfigReply) XXX_DiscardUnknown 

func (m *GetConfigReply) XXX_DiscardUnknown()

func (*GetConfigReply) XXX_Marshal 

func (m *GetConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigReply) XXX_Merge 

func (dst *GetConfigReply) XXX_Merge(src proto.Message)

func (*GetConfigReply) XXX_Size 

func (m *GetConfigReply) XXX_Size() int

func (*GetConfigReply) XXX_Unmarshal 

func (m *GetConfigReply) XXX_Unmarshal(b []byte) error

type GetConfigRequest 

type GetConfigRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetConfigRequest) Descriptor 

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

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) Reset 

func (m *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (m *GetConfigRequest) String() string

func (*GetConfigRequest) XXX_DiscardUnknown 

func (m *GetConfigRequest) XXX_DiscardUnknown()

func (*GetConfigRequest) XXX_Marshal 

func (m *GetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetConfigRequest) XXX_Merge 

func (dst *GetConfigRequest) XXX_Merge(src proto.Message)

func (*GetConfigRequest) XXX_Size 

func (m *GetConfigRequest) XXX_Size() int

func (*GetConfigRequest) XXX_Unmarshal 

func (m *GetConfigRequest) XXX_Unmarshal(b []byte) error

type GetNodeReply 

type GetNodeReply struct {
	Node                 string   `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNodeReply) Descriptor 

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

func (*GetNodeReply) GetNode 

func (m *GetNodeReply) GetNode() string

func (*GetNodeReply) ProtoMessage 

func (*GetNodeReply) ProtoMessage()

func (*GetNodeReply) Reset 

func (m *GetNodeReply) Reset()

func (*GetNodeReply) String 

func (m *GetNodeReply) String() string

func (*GetNodeReply) XXX_DiscardUnknown 

func (m *GetNodeReply) XXX_DiscardUnknown()

func (*GetNodeReply) XXX_Marshal 

func (m *GetNodeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeReply) XXX_Merge 

func (dst *GetNodeReply) XXX_Merge(src proto.Message)

func (*GetNodeReply) XXX_Size 

func (m *GetNodeReply) XXX_Size() int

func (*GetNodeReply) XXX_Unmarshal 

func (m *GetNodeReply) XXX_Unmarshal(b []byte) error

type GetNodeRequest 

type GetNodeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNodeRequest) Descriptor 

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

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) Reset 

func (m *GetNodeRequest) Reset()

func (*GetNodeRequest) String 

func (m *GetNodeRequest) String() string

func (*GetNodeRequest) XXX_DiscardUnknown 

func (m *GetNodeRequest) XXX_DiscardUnknown()

func (*GetNodeRequest) XXX_Marshal 

func (m *GetNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeRequest) XXX_Merge 

func (dst *GetNodeRequest) XXX_Merge(src proto.Message)

func (*GetNodeRequest) XXX_Size 

func (m *GetNodeRequest) XXX_Size() int

func (*GetNodeRequest) XXX_Unmarshal 

func (m *GetNodeRequest) XXX_Unmarshal(b []byte) error

type HealthCheckReply 

type HealthCheckReply struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckReply) Descriptor 

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

func (*HealthCheckReply) GetError 

func (m *HealthCheckReply) GetError() string

func (*HealthCheckReply) ProtoMessage 

func (*HealthCheckReply) ProtoMessage()

func (*HealthCheckReply) Reset 

func (m *HealthCheckReply) Reset()

func (*HealthCheckReply) String 

func (m *HealthCheckReply) String() string

func (*HealthCheckReply) XXX_DiscardUnknown 

func (m *HealthCheckReply) XXX_DiscardUnknown()

func (*HealthCheckReply) XXX_Marshal 

func (m *HealthCheckReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckReply) XXX_Merge 

func (dst *HealthCheckReply) XXX_Merge(src proto.Message)

func (*HealthCheckReply) XXX_Size 

func (m *HealthCheckReply) XXX_Size() int

func (*HealthCheckReply) XXX_Unmarshal 

func (m *HealthCheckReply) XXX_Unmarshal(b []byte) error

type HealthCheckRequest 

type HealthCheckRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckRequest) XXX_Merge 

func (dst *HealthCheckRequest) XXX_Merge(src proto.Message)

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

JsonPatch holds on JSON patch

func (*JsonPatch) Descriptor 

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

func (*JsonPatch) GetOp 

func (m *JsonPatch) GetOp() string

func (*JsonPatch) GetPath 

func (m *JsonPatch) GetPath() string

func (*JsonPatch) GetValue 

func (m *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) Reset 

func (m *JsonPatch) Reset()

func (*JsonPatch) String 

func (m *JsonPatch) String() string

func (*JsonPatch) XXX_DiscardUnknown 

func (m *JsonPatch) XXX_DiscardUnknown()

func (*JsonPatch) XXX_Marshal 

func (m *JsonPatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JsonPatch) XXX_Merge 

func (dst *JsonPatch) XXX_Merge(src proto.Message)

func (*JsonPatch) XXX_Size 

func (m *JsonPatch) XXX_Size() int

func (*JsonPatch) XXX_Unmarshal 

func (m *JsonPatch) XXX_Unmarshal(b []byte) error

type PatchNodeReply 

type PatchNodeReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PatchNodeReply) Descriptor 

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

func (*PatchNodeReply) ProtoMessage 

func (*PatchNodeReply) ProtoMessage()

func (*PatchNodeReply) Reset 

func (m *PatchNodeReply) Reset()

func (*PatchNodeReply) String 

func (m *PatchNodeReply) String() string

func (*PatchNodeReply) XXX_DiscardUnknown 

func (m *PatchNodeReply) XXX_DiscardUnknown()

func (*PatchNodeReply) XXX_Marshal 

func (m *PatchNodeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PatchNodeReply) XXX_Merge 

func (dst *PatchNodeReply) XXX_Merge(src proto.Message)

func (*PatchNodeReply) XXX_Size 

func (m *PatchNodeReply) XXX_Size() int

func (*PatchNodeReply) XXX_Unmarshal 

func (m *PatchNodeReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PatchNodeRequest) Descriptor 

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

func (*PatchNodeRequest) GetPatches 

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

func (*PatchNodeRequest) ProtoMessage 

func (*PatchNodeRequest) ProtoMessage()

func (*PatchNodeRequest) Reset 

func (m *PatchNodeRequest) Reset()

func (*PatchNodeRequest) String 

func (m *PatchNodeRequest) String() string

func (*PatchNodeRequest) XXX_DiscardUnknown 

func (m *PatchNodeRequest) XXX_DiscardUnknown()

func (*PatchNodeRequest) XXX_Marshal 

func (m *PatchNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PatchNodeRequest) XXX_Merge 

func (dst *PatchNodeRequest) XXX_Merge(src proto.Message)

func (*PatchNodeRequest) XXX_Size 

func (m *PatchNodeRequest) XXX_Size() int

func (*PatchNodeRequest) XXX_Unmarshal 

func (m *PatchNodeRequest) XXX_Unmarshal(b []byte) error

type UpdateNodeCapacityReply 

type UpdateNodeCapacityReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateNodeCapacityReply) Descriptor 

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

func (*UpdateNodeCapacityReply) ProtoMessage 

func (*UpdateNodeCapacityReply) ProtoMessage()

func (*UpdateNodeCapacityReply) Reset 

func (m *UpdateNodeCapacityReply) Reset()

func (*UpdateNodeCapacityReply) String 

func (m *UpdateNodeCapacityReply) String() string

func (*UpdateNodeCapacityReply) XXX_DiscardUnknown 

func (m *UpdateNodeCapacityReply) XXX_DiscardUnknown()

func (*UpdateNodeCapacityReply) XXX_Marshal 

func (m *UpdateNodeCapacityReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateNodeCapacityReply) XXX_Merge 

func (dst *UpdateNodeCapacityReply) XXX_Merge(src proto.Message)

func (*UpdateNodeCapacityReply) XXX_Size 

func (m *UpdateNodeCapacityReply) XXX_Size() int

func (*UpdateNodeCapacityReply) XXX_Unmarshal 

func (m *UpdateNodeCapacityReply) XXX_Unmarshal(b []byte) error

type UpdateNodeCapacityRequest 

type UpdateNodeCapacityRequest struct {
	// Name-value map of status.capacity to update
	Capacities           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateNodeCapacityRequest) Descriptor 

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

func (*UpdateNodeCapacityRequest) GetCapacities 

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

func (*UpdateNodeCapacityRequest) ProtoMessage 

func (*UpdateNodeCapacityRequest) ProtoMessage()

func (*UpdateNodeCapacityRequest) Reset 

func (m *UpdateNodeCapacityRequest) Reset()

func (*UpdateNodeCapacityRequest) String 

func (m *UpdateNodeCapacityRequest) String() string

func (*UpdateNodeCapacityRequest) XXX_DiscardUnknown 

func (m *UpdateNodeCapacityRequest) XXX_DiscardUnknown()

func (*UpdateNodeCapacityRequest) XXX_Marshal 

func (m *UpdateNodeCapacityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateNodeCapacityRequest) XXX_Merge 

func (dst *UpdateNodeCapacityRequest) XXX_Merge(src proto.Message)

func (*UpdateNodeCapacityRequest) XXX_Size 

func (m *UpdateNodeCapacityRequest) XXX_Size() int

func (*UpdateNodeCapacityRequest) XXX_Unmarshal 

func (m *UpdateNodeCapacityRequest) XXX_Unmarshal(b []byte) error

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.