server

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2021 License: Apache-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMConfigServer 

func RegisterMConfigServer(s *grpc.Server, srv MConfigServer)

Types

type ConfigVal 

type ConfigVal struct {
	ConfigKey            string   `protobuf:"bytes,1,opt,name=config_key,json=configKey,proto3" json:"config_key,omitempty"`
	Val                  string   `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigVal) Descriptor 

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

func (*ConfigVal) GetConfigKey 

func (m *ConfigVal) GetConfigKey() string

func (*ConfigVal) GetVal 

func (m *ConfigVal) GetVal() string

func (*ConfigVal) ProtoMessage 

func (*ConfigVal) ProtoMessage()

func (*ConfigVal) Reset 

func (m *ConfigVal) Reset()

func (*ConfigVal) String 

func (m *ConfigVal) String() string

func (*ConfigVal) XXX_DiscardUnknown 

func (m *ConfigVal) XXX_DiscardUnknown()

func (*ConfigVal) XXX_Marshal 

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

func (*ConfigVal) XXX_Merge 

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

func (*ConfigVal) XXX_Size 

func (m *ConfigVal) XXX_Size() int

func (*ConfigVal) XXX_Unmarshal 

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

type DeletConfigRequest 

type DeletConfigRequest struct {
	App                  string   `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Env                  string   `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Config               string   `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletConfigRequest) Descriptor 

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

func (*DeletConfigRequest) GetApp 

func (m *DeletConfigRequest) GetApp() string

func (*DeletConfigRequest) GetConfig 

func (m *DeletConfigRequest) GetConfig() string

func (*DeletConfigRequest) GetEnv 

func (m *DeletConfigRequest) GetEnv() string

func (*DeletConfigRequest) ProtoMessage 

func (*DeletConfigRequest) ProtoMessage()

func (*DeletConfigRequest) Reset 

func (m *DeletConfigRequest) Reset()

func (*DeletConfigRequest) String 

func (m *DeletConfigRequest) String() string

func (*DeletConfigRequest) XXX_DiscardUnknown 

func (m *DeletConfigRequest) XXX_DiscardUnknown()

func (*DeletConfigRequest) XXX_Marshal 

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

func (*DeletConfigRequest) XXX_Merge 

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

func (*DeletConfigRequest) XXX_Size 

func (m *DeletConfigRequest) XXX_Size() int

func (*DeletConfigRequest) XXX_Unmarshal 

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

type DeletFilterRequest 

type DeletFilterRequest struct {
	App                  string   `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Env                  string   `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletFilterRequest) Descriptor 

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

func (*DeletFilterRequest) GetApp 

func (m *DeletFilterRequest) GetApp() string

func (*DeletFilterRequest) GetEnv 

func (m *DeletFilterRequest) GetEnv() string

func (*DeletFilterRequest) ProtoMessage 

func (*DeletFilterRequest) ProtoMessage()

func (*DeletFilterRequest) Reset 

func (m *DeletFilterRequest) Reset()

func (*DeletFilterRequest) String 

func (m *DeletFilterRequest) String() string

func (*DeletFilterRequest) XXX_DiscardUnknown 

func (m *DeletFilterRequest) XXX_DiscardUnknown()

func (*DeletFilterRequest) XXX_Marshal 

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

func (*DeletFilterRequest) XXX_Merge 

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

func (*DeletFilterRequest) XXX_Size 

func (m *DeletFilterRequest) XXX_Size() int

func (*DeletFilterRequest) XXX_Unmarshal 

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

type GetNodeDetailResponse 

type GetNodeDetailResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNodeDetailResponse) Descriptor 

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

func (*GetNodeDetailResponse) GetData 

func (m *GetNodeDetailResponse) GetData() []byte

func (*GetNodeDetailResponse) ProtoMessage 

func (*GetNodeDetailResponse) ProtoMessage()

func (*GetNodeDetailResponse) Reset 

func (m *GetNodeDetailResponse) Reset()

func (*GetNodeDetailResponse) String 

func (m *GetNodeDetailResponse) String() string

func (*GetNodeDetailResponse) XXX_DiscardUnknown 

func (m *GetNodeDetailResponse) XXX_DiscardUnknown()

func (*GetNodeDetailResponse) XXX_Marshal 

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

func (*GetNodeDetailResponse) XXX_Merge 

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

func (*GetNodeDetailResponse) XXX_Size 

func (m *GetNodeDetailResponse) XXX_Size() int

func (*GetNodeDetailResponse) XXX_Unmarshal 

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

type GetNodeStoreDataRequest 

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

func (*GetNodeStoreDataRequest) Descriptor 

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

func (*GetNodeStoreDataRequest) ProtoMessage 

func (*GetNodeStoreDataRequest) ProtoMessage()

func (*GetNodeStoreDataRequest) Reset 

func (m *GetNodeStoreDataRequest) Reset()

func (*GetNodeStoreDataRequest) String 

func (m *GetNodeStoreDataRequest) String() string

func (*GetNodeStoreDataRequest) XXX_DiscardUnknown 

func (m *GetNodeStoreDataRequest) XXX_DiscardUnknown()

func (*GetNodeStoreDataRequest) XXX_Marshal 

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

func (*GetNodeStoreDataRequest) XXX_Merge 

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

func (*GetNodeStoreDataRequest) XXX_Size 

func (m *GetNodeStoreDataRequest) XXX_Size() int

func (*GetNodeStoreDataRequest) XXX_Unmarshal 

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

type GetNodeStoreDataResponse 

type GetNodeStoreDataResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetNodeStoreDataResponse) Descriptor 

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

func (*GetNodeStoreDataResponse) GetData 

func (m *GetNodeStoreDataResponse) GetData() []byte

func (*GetNodeStoreDataResponse) ProtoMessage 

func (*GetNodeStoreDataResponse) ProtoMessage()

func (*GetNodeStoreDataResponse) Reset 

func (m *GetNodeStoreDataResponse) Reset()

func (*GetNodeStoreDataResponse) String 

func (m *GetNodeStoreDataResponse) String() string

func (*GetNodeStoreDataResponse) XXX_DiscardUnknown 

func (m *GetNodeStoreDataResponse) XXX_DiscardUnknown()

func (*GetNodeStoreDataResponse) XXX_Marshal 

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

func (*GetNodeStoreDataResponse) XXX_Merge 

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

func (*GetNodeStoreDataResponse) XXX_Size 

func (m *GetNodeStoreDataResponse) XXX_Size() int

func (*GetNodeStoreDataResponse) XXX_Unmarshal 

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

type MConfigClient 

type MConfigClient interface {
	WatchConfigStream(ctx context.Context, opts ...grpc.CallOption) (MConfig_WatchConfigStreamClient, error)
	GetNodeStoreData(ctx context.Context, in *GetNodeStoreDataRequest, opts ...grpc.CallOption) (*GetNodeStoreDataResponse, error)
	UpdateConfig(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfiResponse, error)
	UpdateFilter(ctx context.Context, in *UpdateFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetNodeDetail(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetNodeDetailResponse, error)
	DeletConfig(ctx context.Context, in *DeletConfigRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	DeletFilter(ctx context.Context, in *DeletFilterRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

MConfigClient is the client API for MConfig service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMConfigClient 

func NewMConfigClient(cc *grpc.ClientConn) MConfigClient

type MConfigServer 

type MConfigServer interface {
	WatchConfigStream(MConfig_WatchConfigStreamServer) error
	GetNodeStoreData(context.Context, *GetNodeStoreDataRequest) (*GetNodeStoreDataResponse, error)
	UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfiResponse, error)
	UpdateFilter(context.Context, *UpdateFilterRequest) (*empty.Empty, error)
	GetNodeDetail(context.Context, *empty.Empty) (*GetNodeDetailResponse, error)
	DeletConfig(context.Context, *DeletConfigRequest) (*empty.Empty, error)
	DeletFilter(context.Context, *DeletFilterRequest) (*empty.Empty, error)
}

MConfigServer is the server API for MConfig service.

type MConfig_WatchConfigStreamClient 

type MConfig_WatchConfigStreamClient interface {
	Send(*WatchConfigStreamRequest) error
	Recv() (*WatchConfigStreamResponse, error)
	grpc.ClientStream
}

type MConfig_WatchConfigStreamServer 

type MConfig_WatchConfigStreamServer interface {
	Send(*WatchConfigStreamResponse) error
	Recv() (*WatchConfigStreamRequest, error)
	grpc.ServerStream
}

type UnimplementedMConfigServer 

type UnimplementedMConfigServer struct {
}

UnimplementedMConfigServer can be embedded to have forward compatible implementations.

func (*UnimplementedMConfigServer) DeletConfig 

func (*UnimplementedMConfigServer) DeletConfig(ctx context.Context, req *DeletConfigRequest) (*empty.Empty, error)

func (*UnimplementedMConfigServer) DeletFilter 

func (*UnimplementedMConfigServer) DeletFilter(ctx context.Context, req *DeletFilterRequest) (*empty.Empty, error)

func (*UnimplementedMConfigServer) GetNodeDetail 

func (*UnimplementedMConfigServer) GetNodeDetail(ctx context.Context, req *empty.Empty) (*GetNodeDetailResponse, error)

func (*UnimplementedMConfigServer) GetNodeStoreData 

func (*UnimplementedMConfigServer) GetNodeStoreData(ctx context.Context, req *GetNodeStoreDataRequest) (*GetNodeStoreDataResponse, error)

func (*UnimplementedMConfigServer) UpdateConfig 

func (*UnimplementedMConfigServer) UpdateConfig(ctx context.Context, req *UpdateConfigRequest) (*UpdateConfiResponse, error)

func (*UnimplementedMConfigServer) UpdateFilter 

func (*UnimplementedMConfigServer) UpdateFilter(ctx context.Context, req *UpdateFilterRequest) (*empty.Empty, error)

func (*UnimplementedMConfigServer) WatchConfigStream 

func (*UnimplementedMConfigServer) WatchConfigStream(srv MConfig_WatchConfigStreamServer) error

type UpdateConfiResponse 

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

func (*UpdateConfiResponse) Descriptor 

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

func (*UpdateConfiResponse) ProtoMessage 

func (*UpdateConfiResponse) ProtoMessage()

func (*UpdateConfiResponse) Reset 

func (m *UpdateConfiResponse) Reset()

func (*UpdateConfiResponse) String 

func (m *UpdateConfiResponse) String() string

func (*UpdateConfiResponse) XXX_DiscardUnknown 

func (m *UpdateConfiResponse) XXX_DiscardUnknown()

func (*UpdateConfiResponse) XXX_Marshal 

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

func (*UpdateConfiResponse) XXX_Merge 

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

func (*UpdateConfiResponse) XXX_Size 

func (m *UpdateConfiResponse) XXX_Size() int

func (*UpdateConfiResponse) XXX_Unmarshal 

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

type UpdateConfigRequest 

type UpdateConfigRequest struct {
	App                  string   `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Env                  string   `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Config               string   `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Filter               string   `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	Val                  string   `protobuf:"bytes,5,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateConfigRequest) Descriptor 

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

func (*UpdateConfigRequest) GetApp 

func (m *UpdateConfigRequest) GetApp() string

func (*UpdateConfigRequest) GetConfig 

func (m *UpdateConfigRequest) GetConfig() string

func (*UpdateConfigRequest) GetEnv 

func (m *UpdateConfigRequest) GetEnv() string

func (*UpdateConfigRequest) GetFilter 

func (m *UpdateConfigRequest) GetFilter() string

func (*UpdateConfigRequest) GetVal 

func (m *UpdateConfigRequest) GetVal() string

func (*UpdateConfigRequest) ProtoMessage 

func (*UpdateConfigRequest) ProtoMessage()

func (*UpdateConfigRequest) Reset 

func (m *UpdateConfigRequest) Reset()

func (*UpdateConfigRequest) String 

func (m *UpdateConfigRequest) String() string

func (*UpdateConfigRequest) XXX_DiscardUnknown 

func (m *UpdateConfigRequest) XXX_DiscardUnknown()

func (*UpdateConfigRequest) XXX_Marshal 

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

func (*UpdateConfigRequest) XXX_Merge 

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

func (*UpdateConfigRequest) XXX_Size 

func (m *UpdateConfigRequest) XXX_Size() int

func (*UpdateConfigRequest) XXX_Unmarshal 

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

type UpdateFilterRequest 

type UpdateFilterRequest struct {
	App                  string   `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Env                  string   `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Filter               string   `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateFilterRequest) Descriptor 

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

func (*UpdateFilterRequest) GetApp 

func (m *UpdateFilterRequest) GetApp() string

func (*UpdateFilterRequest) GetEnv 

func (m *UpdateFilterRequest) GetEnv() string

func (*UpdateFilterRequest) GetFilter 

func (m *UpdateFilterRequest) GetFilter() string

func (*UpdateFilterRequest) ProtoMessage 

func (*UpdateFilterRequest) ProtoMessage()

func (*UpdateFilterRequest) Reset 

func (m *UpdateFilterRequest) Reset()

func (*UpdateFilterRequest) String 

func (m *UpdateFilterRequest) String() string

func (*UpdateFilterRequest) XXX_DiscardUnknown 

func (m *UpdateFilterRequest) XXX_DiscardUnknown()

func (*UpdateFilterRequest) XXX_Marshal 

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

func (*UpdateFilterRequest) XXX_Merge 

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

func (*UpdateFilterRequest) XXX_Size 

func (m *UpdateFilterRequest) XXX_Size() int

func (*UpdateFilterRequest) XXX_Unmarshal 

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

type WatchConfigStreamRequest 

type WatchConfigStreamRequest struct {
	AppKey               string            `protobuf:"bytes,1,opt,name=app_key,json=appKey,proto3" json:"app_key,omitempty"`
	ConfigKeys           []string          `protobuf:"bytes,2,rep,name=config_keys,json=configKeys,proto3" json:"config_keys,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WatchConfigStreamRequest) Descriptor 

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

func (*WatchConfigStreamRequest) GetAppKey 

func (m *WatchConfigStreamRequest) GetAppKey() string

func (*WatchConfigStreamRequest) GetConfigKeys 

func (m *WatchConfigStreamRequest) GetConfigKeys() []string

func (*WatchConfigStreamRequest) GetMetadata 

func (m *WatchConfigStreamRequest) GetMetadata() map[string]string

func (*WatchConfigStreamRequest) ProtoMessage 

func (*WatchConfigStreamRequest) ProtoMessage()

func (*WatchConfigStreamRequest) Reset 

func (m *WatchConfigStreamRequest) Reset()

func (*WatchConfigStreamRequest) String 

func (m *WatchConfigStreamRequest) String() string

func (*WatchConfigStreamRequest) XXX_DiscardUnknown 

func (m *WatchConfigStreamRequest) XXX_DiscardUnknown()

func (*WatchConfigStreamRequest) XXX_Marshal 

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

func (*WatchConfigStreamRequest) XXX_Merge 

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

func (*WatchConfigStreamRequest) XXX_Size 

func (m *WatchConfigStreamRequest) XXX_Size() int

func (*WatchConfigStreamRequest) XXX_Unmarshal 

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

type WatchConfigStreamResponse 

type WatchConfigStreamResponse struct {
	Configs              []*ConfigVal `protobuf:"bytes,1,rep,name=configs,proto3" json:"configs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WatchConfigStreamResponse) Descriptor 

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

func (*WatchConfigStreamResponse) GetConfigs 

func (m *WatchConfigStreamResponse) GetConfigs() []*ConfigVal

func (*WatchConfigStreamResponse) ProtoMessage 

func (*WatchConfigStreamResponse) ProtoMessage()

func (*WatchConfigStreamResponse) Reset 

func (m *WatchConfigStreamResponse) Reset()

func (*WatchConfigStreamResponse) String 

func (m *WatchConfigStreamResponse) String() string

func (*WatchConfigStreamResponse) XXX_DiscardUnknown 

func (m *WatchConfigStreamResponse) XXX_DiscardUnknown()

func (*WatchConfigStreamResponse) XXX_Marshal 

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

func (*WatchConfigStreamResponse) XXX_Merge 

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

func (*WatchConfigStreamResponse) XXX_Size 

func (m *WatchConfigStreamResponse) XXX_Size() int

func (*WatchConfigStreamResponse) XXX_Unmarshal 

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