v1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 2020 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterConfigServer 

func RegisterConfigServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewConfigClient 

func NewConfigClient(cc *grpc.ClientConn) ConfigClient

type ConfigServer 

type ConfigServer interface {
	SetConfig(context.Context, *SetConfigRequest) (*SetConfigReply, error)
	SetAdjustment(context.Context, *SetAdjustmentRequest) (*SetAdjustmentReply, error)
}

ConfigServer is the server API for Config service.

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

func (*SetAdjustmentReply) Descriptor added in v0.4.0 

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

func (*SetAdjustmentReply) GetErrors added in v0.4.0 

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

func (*SetAdjustmentReply) ProtoMessage added in v0.4.0 

func (*SetAdjustmentReply) ProtoMessage()

func (*SetAdjustmentReply) Reset added in v0.4.0 

func (m *SetAdjustmentReply) Reset()

func (*SetAdjustmentReply) String added in v0.4.0 

func (m *SetAdjustmentReply) String() string

func (*SetAdjustmentReply) XXX_DiscardUnknown added in v0.4.0 

func (m *SetAdjustmentReply) XXX_DiscardUnknown()

func (*SetAdjustmentReply) XXX_Marshal added in v0.4.0 

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

func (*SetAdjustmentReply) XXX_Merge added in v0.4.0 

func (m *SetAdjustmentReply) XXX_Merge(src proto.Message)

func (*SetAdjustmentReply) XXX_Size added in v0.4.0 

func (m *SetAdjustmentReply) XXX_Size() int

func (*SetAdjustmentReply) XXX_Unmarshal added in v0.4.0 

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

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

func (*SetAdjustmentRequest) Descriptor added in v0.4.0 

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

func (*SetAdjustmentRequest) GetAdjustment added in v0.4.0 

func (m *SetAdjustmentRequest) GetAdjustment() string

func (*SetAdjustmentRequest) GetNodeName added in v0.4.0 

func (m *SetAdjustmentRequest) GetNodeName() string

func (*SetAdjustmentRequest) ProtoMessage added in v0.4.0 

func (*SetAdjustmentRequest) ProtoMessage()

func (*SetAdjustmentRequest) Reset added in v0.4.0 

func (m *SetAdjustmentRequest) Reset()

func (*SetAdjustmentRequest) String added in v0.4.0 

func (m *SetAdjustmentRequest) String() string

func (*SetAdjustmentRequest) XXX_DiscardUnknown added in v0.4.0 

func (m *SetAdjustmentRequest) XXX_DiscardUnknown()

func (*SetAdjustmentRequest) XXX_Marshal added in v0.4.0 

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

func (*SetAdjustmentRequest) XXX_Merge added in v0.4.0 

func (m *SetAdjustmentRequest) XXX_Merge(src proto.Message)

func (*SetAdjustmentRequest) XXX_Size added in v0.4.0 

func (m *SetAdjustmentRequest) XXX_Size() int

func (*SetAdjustmentRequest) XXX_Unmarshal added in v0.4.0 

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

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

func (*SetConfigReply) Descriptor 

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

func (*SetConfigReply) GetError 

func (m *SetConfigReply) GetError() string

func (*SetConfigReply) ProtoMessage 

func (*SetConfigReply) ProtoMessage()

func (*SetConfigReply) Reset 

func (m *SetConfigReply) Reset()

func (*SetConfigReply) String 

func (m *SetConfigReply) String() string

func (*SetConfigReply) XXX_DiscardUnknown 

func (m *SetConfigReply) XXX_DiscardUnknown()

func (*SetConfigReply) XXX_Marshal 

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

func (*SetConfigReply) XXX_Merge 

func (m *SetConfigReply) XXX_Merge(src proto.Message)

func (*SetConfigReply) XXX_Size 

func (m *SetConfigReply) XXX_Size() int

func (*SetConfigReply) XXX_Unmarshal 

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

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

func (*SetConfigRequest) Descriptor 

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

func (*SetConfigRequest) GetConfig 

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

func (*SetConfigRequest) GetNodeName 

func (m *SetConfigRequest) GetNodeName() string

func (*SetConfigRequest) ProtoMessage 

func (*SetConfigRequest) ProtoMessage()

func (*SetConfigRequest) Reset 

func (m *SetConfigRequest) Reset()

func (*SetConfigRequest) String 

func (m *SetConfigRequest) String() string

func (*SetConfigRequest) XXX_DiscardUnknown 

func (m *SetConfigRequest) XXX_DiscardUnknown()

func (*SetConfigRequest) XXX_Marshal 

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

func (*SetConfigRequest) XXX_Merge 

func (m *SetConfigRequest) XXX_Merge(src proto.Message)

func (*SetConfigRequest) XXX_Size 

func (m *SetConfigRequest) XXX_Size() int

func (*SetConfigRequest) XXX_Unmarshal 

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

type UnimplementedConfigServer 

type UnimplementedConfigServer struct {
}

UnimplementedConfigServer can be embedded to have forward compatible implementations.

func (*UnimplementedConfigServer) SetAdjustment added in v0.4.0 

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

func (*UnimplementedConfigServer) SetConfig 

func (*UnimplementedConfigServer) SetConfig(ctx context.Context, req *SetConfigRequest) (*SetConfigReply, 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.