v1

Documentation

Index

• func RegisterConfigServer(s *grpc.Server, srv ConfigServer)
• type ConfigClient
  • func NewConfigClient(cc *grpc.ClientConn) ConfigClient
• type ConfigServer
• type SetConfigReply
  • func (*SetConfigReply) Descriptor() ([]byte, []int)
  • func (m *SetConfigReply) GetError() string
  • func (*SetConfigReply) ProtoMessage()
  • func (m *SetConfigReply) Reset()
  • func (m *SetConfigReply) String() string
  • func (m *SetConfigReply) XXX_DiscardUnknown()
  • func (m *SetConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SetConfigReply) XXX_Merge(src proto.Message)
  • func (m *SetConfigReply) XXX_Size() int
  • func (m *SetConfigReply) XXX_Unmarshal(b []byte) error
• type SetConfigRequest
  • func (*SetConfigRequest) Descriptor() ([]byte, []int)
  • func (m *SetConfigRequest) GetConfig() map[string]string
  • func (m *SetConfigRequest) GetNodeName() string
  • func (*SetConfigRequest) ProtoMessage()
  • func (m *SetConfigRequest) Reset()
  • func (m *SetConfigRequest) String() string
  • func (m *SetConfigRequest) XXX_DiscardUnknown()
  • func (m *SetConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SetConfigRequest) XXX_Merge(src proto.Message)
  • func (m *SetConfigRequest) XXX_Size() int
  • func (m *SetConfigRequest) XXX_Unmarshal(b []byte) error
• type UnimplementedConfigServer
  • func (*UnimplementedConfigServer) SetConfig(ctx context.Context, req *SetConfigRequest) (*SetConfigReply, error)

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)
}

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)
}

ConfigServer is the server API for Config service.

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 {
	// Name
	NodeName string `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// Key-value map of 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) SetConfig

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