service

package
v1.15.7 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StatusCode_name = map[int32]string{
		0: "SUCCESS",
		1: "FAIL",
		2: "SKILL",
	}
	StatusCode_value = map[string]int32{
		"SUCCESS": 0,
		"FAIL":    1,
		"SKILL":   2,
	}
)

Enum value maps for StatusCode.

View Source 
var CtiService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.CtiService",
	HandlerType: (*CtiServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Join",
			Handler:    _CtiService_Join_Handler,
		},
		{
			MethodName: "Leave",
			Handler:    _CtiService_Leave_Handler,
		},
		{
			MethodName: "List",
			Handler:    _CtiService_List_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _CtiService_Info_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _CtiService_Remove_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ctl.proto",
}

CtiService_ServiceDesc is the grpc.ServiceDesc for CtiService 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_ctl_proto protoreflect.FileDescriptor
View Source 
var File_event_proto protoreflect.FileDescriptor
View Source 
var File_extender_proto protoreflect.FileDescriptor
View Source 
var File_master_proto protoreflect.FileDescriptor
View Source 
var File_status_proto protoreflect.FileDescriptor
View Source 
var MasterDispatcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "service.MasterDispatcher",
	HandlerType: (*MasterDispatcherServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Listen",
			Handler:       _MasterDispatcher_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "master.proto",
}

MasterDispatcher_ServiceDesc is the grpc.ServiceDesc for MasterDispatcher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCtiServiceServer 

func RegisterCtiServiceServer(s grpc.ServiceRegistrar, srv CtiServiceServer)

func RegisterMasterDispatcherServer 

func RegisterMasterDispatcherServer(s grpc.ServiceRegistrar, srv MasterDispatcherServer)

func ServerAddr 

func ServerAddr(pid int, name string) string

func ServerUnixAddr 

func ServerUnixAddr(pid int, name string) string

Types

type CtiServiceClient 

type CtiServiceClient interface {
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
}

CtiServiceClient is the client API for CtiService 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 NewCtiServiceClient 

func NewCtiServiceClient(cc grpc.ClientConnInterface) CtiServiceClient

type CtiServiceServer 

type CtiServiceServer interface {
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	// contains filtered or unexported methods
}

CtiServiceServer is the server API for CtiService service. All implementations must embed UnimplementedCtiServiceServer for forward compatibility

type EmptyRequest 

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

func (*EmptyRequest) Descriptor deprecated 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

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

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

type EnvConfig 

type EnvConfig struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvConfig) Descriptor deprecated 

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

Deprecated: Use EnvConfig.ProtoReflect.Descriptor instead.

func (*EnvConfig) GetKey 

func (x *EnvConfig) GetKey() string

func (*EnvConfig) GetValue 

func (x *EnvConfig) GetValue() string

func (*EnvConfig) ProtoMessage 

func (*EnvConfig) ProtoMessage()

func (*EnvConfig) ProtoReflect 

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

func (*EnvConfig) Reset 

func (x *EnvConfig) Reset()

func (*EnvConfig) String 

func (x *EnvConfig) String() string

type Event 

type Event struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Command   string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	Key       string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Data      []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetCommand 

func (x *Event) GetCommand() string

func (*Event) GetData 

func (x *Event) GetData() []byte

func (*Event) GetKey 

func (x *Event) GetKey() string

func (*Event) GetNamespace 

func (x *Event) GetNamespace() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type ExtendsBasicInfo 

type ExtendsBasicInfo struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Group   string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Msg     string `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsBasicInfo) Descriptor deprecated 

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

Deprecated: Use ExtendsBasicInfo.ProtoReflect.Descriptor instead.

func (*ExtendsBasicInfo) GetGroup 

func (x *ExtendsBasicInfo) GetGroup() string

func (*ExtendsBasicInfo) GetMsg 

func (x *ExtendsBasicInfo) GetMsg() string

func (*ExtendsBasicInfo) GetName 

func (x *ExtendsBasicInfo) GetName() string

func (*ExtendsBasicInfo) GetProject 

func (x *ExtendsBasicInfo) GetProject() string

func (*ExtendsBasicInfo) GetVersion 

func (x *ExtendsBasicInfo) GetVersion() string

func (*ExtendsBasicInfo) ProtoMessage 

func (*ExtendsBasicInfo) ProtoMessage()

func (*ExtendsBasicInfo) ProtoReflect 

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

func (*ExtendsBasicInfo) Reset 

func (x *ExtendsBasicInfo) Reset()

func (*ExtendsBasicInfo) String 

func (x *ExtendsBasicInfo) String() string

type ExtendsInfo 

type ExtendsInfo struct {
	Id      string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group   string    `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Project string    `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	Version string    `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Plugins []*Plugin `protobuf:"bytes,6,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsInfo) Descriptor deprecated 

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

Deprecated: Use ExtendsInfo.ProtoReflect.Descriptor instead.

func (*ExtendsInfo) GetGroup 

func (x *ExtendsInfo) GetGroup() string

func (*ExtendsInfo) GetId 

func (x *ExtendsInfo) GetId() string

func (*ExtendsInfo) GetName 

func (x *ExtendsInfo) GetName() string

func (*ExtendsInfo) GetPlugins 

func (x *ExtendsInfo) GetPlugins() []*Plugin

func (*ExtendsInfo) GetProject 

func (x *ExtendsInfo) GetProject() string

func (*ExtendsInfo) GetVersion 

func (x *ExtendsInfo) GetVersion() string

func (*ExtendsInfo) ProtoMessage 

func (*ExtendsInfo) ProtoMessage()

func (*ExtendsInfo) ProtoReflect 

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

func (*ExtendsInfo) Reset 

func (x *ExtendsInfo) Reset()

func (*ExtendsInfo) String 

func (x *ExtendsInfo) String() string

type ExtendsInstallRequest 

type ExtendsInstallRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsInstallRequest) Descriptor deprecated 

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

Deprecated: Use ExtendsInstallRequest.ProtoReflect.Descriptor instead.

func (*ExtendsInstallRequest) GetExtends 

func (x *ExtendsInstallRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsInstallRequest) ProtoMessage 

func (*ExtendsInstallRequest) ProtoMessage()

func (*ExtendsInstallRequest) ProtoReflect 

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

func (*ExtendsInstallRequest) Reset 

func (x *ExtendsInstallRequest) Reset()

func (*ExtendsInstallRequest) String 

func (x *ExtendsInstallRequest) String() string

type ExtendsRequest 

type ExtendsRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsRequest) Descriptor deprecated 

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

Deprecated: Use ExtendsRequest.ProtoReflect.Descriptor instead.

func (*ExtendsRequest) GetExtends 

func (x *ExtendsRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsRequest) ProtoMessage 

func (*ExtendsRequest) ProtoMessage()

func (*ExtendsRequest) ProtoReflect 

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

func (*ExtendsRequest) Reset 

func (x *ExtendsRequest) Reset()

func (*ExtendsRequest) String 

func (x *ExtendsRequest) String() string

type ExtendsResponse 

type ExtendsResponse struct {
	Msg         string              `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code        string              `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Extends     []*ExtendsInfo      `protobuf:"bytes,3,rep,name=extends,proto3" json:"extends,omitempty"`
	FailExtends []*ExtendsBasicInfo `protobuf:"bytes,4,rep,name=failExtends,proto3" json:"failExtends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsResponse) Descriptor deprecated 

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

Deprecated: Use ExtendsResponse.ProtoReflect.Descriptor instead.

func (*ExtendsResponse) GetCode 

func (x *ExtendsResponse) GetCode() string

func (*ExtendsResponse) GetExtends 

func (x *ExtendsResponse) GetExtends() []*ExtendsInfo

func (*ExtendsResponse) GetFailExtends 

func (x *ExtendsResponse) GetFailExtends() []*ExtendsBasicInfo

func (*ExtendsResponse) GetMsg 

func (x *ExtendsResponse) GetMsg() string

func (*ExtendsResponse) ProtoMessage 

func (*ExtendsResponse) ProtoMessage()

func (*ExtendsResponse) ProtoReflect 

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

func (*ExtendsResponse) Reset 

func (x *ExtendsResponse) Reset()

func (*ExtendsResponse) String 

func (x *ExtendsResponse) String() string

type ExtendsUninstallResponse 

type ExtendsUninstallResponse struct {
	Msg         string              `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code        string              `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Extends     []*ExtendsBasicInfo `protobuf:"bytes,3,rep,name=extends,proto3" json:"extends,omitempty"`
	FailExtends []*ExtendsBasicInfo `protobuf:"bytes,4,rep,name=failExtends,proto3" json:"failExtends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsUninstallResponse) Descriptor deprecated 

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

Deprecated: Use ExtendsUninstallResponse.ProtoReflect.Descriptor instead.

func (*ExtendsUninstallResponse) GetCode 

func (x *ExtendsUninstallResponse) GetCode() string

func (*ExtendsUninstallResponse) GetExtends 

func (x *ExtendsUninstallResponse) GetExtends() []*ExtendsBasicInfo

func (*ExtendsUninstallResponse) GetFailExtends 

func (x *ExtendsUninstallResponse) GetFailExtends() []*ExtendsBasicInfo

func (*ExtendsUninstallResponse) GetMsg 

func (x *ExtendsUninstallResponse) GetMsg() string

func (*ExtendsUninstallResponse) ProtoMessage 

func (*ExtendsUninstallResponse) ProtoMessage()

func (*ExtendsUninstallResponse) ProtoReflect 

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

func (*ExtendsUninstallResponse) Reset 

func (x *ExtendsUninstallResponse) Reset()

func (*ExtendsUninstallResponse) String 

func (x *ExtendsUninstallResponse) String() string

type ExtendsUpdateRequest 

type ExtendsUpdateRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsUpdateRequest) Descriptor deprecated 

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

Deprecated: Use ExtendsUpdateRequest.ProtoReflect.Descriptor instead.

func (*ExtendsUpdateRequest) GetExtends 

func (x *ExtendsUpdateRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsUpdateRequest) ProtoMessage 

func (*ExtendsUpdateRequest) ProtoMessage()

func (*ExtendsUpdateRequest) ProtoReflect 

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

func (*ExtendsUpdateRequest) Reset 

func (x *ExtendsUpdateRequest) Reset()

func (*ExtendsUpdateRequest) String 

func (x *ExtendsUpdateRequest) String() string

type IExtenderPluginSetting 

type IExtenderPluginSetting interface {
	GetPlugin(pluginID string) (*Plugin, error)
	Plugins(extenderName string) ([]*Plugin, error)
}

type IExtenderSetting 

type IExtenderSetting interface {
	Reset(data []*ExtendsInfo) error
	Save(extenderName string, data *ExtendsInfo) error
	Del(extenderName string) (*ExtendsInfo, error)
	List(sortItem string, desc bool) ([]*ExtendsInfo, error)
	IExtenderPluginSetting
}

type InfoRequest 

type InfoRequest struct {
	Secret *NodeSecret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) GetSecret 

func (x *InfoRequest) GetSecret() *NodeSecret

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

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

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Msg     string    `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code    string    `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Info    *NodeInfo `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	Cluster string    `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetCluster 

func (x *InfoResponse) GetCluster() string

func (*InfoResponse) GetCode 

func (x *InfoResponse) GetCode() string

func (*InfoResponse) GetInfo 

func (x *InfoResponse) GetInfo() *NodeInfo

func (*InfoResponse) GetMsg 

func (x *InfoResponse) GetMsg() string

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

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

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type JoinRequest 

type JoinRequest struct {
	ClusterAddress []string `protobuf:"bytes,4,rep,name=clusterAddress,proto3" json:"clusterAddress,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinRequest) Descriptor deprecated 

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

Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.

func (*JoinRequest) GetClusterAddress 

func (x *JoinRequest) GetClusterAddress() []string

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) ProtoReflect 

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

func (*JoinRequest) Reset 

func (x *JoinRequest) Reset()

func (*JoinRequest) String 

func (x *JoinRequest) String() string

type JoinResponse 

type JoinResponse struct {
	Msg  string      `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code string      `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Info *NodeSecret `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinResponse) Descriptor deprecated 

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

Deprecated: Use JoinResponse.ProtoReflect.Descriptor instead.

func (*JoinResponse) GetCode 

func (x *JoinResponse) GetCode() string

func (*JoinResponse) GetInfo 

func (x *JoinResponse) GetInfo() *NodeSecret

func (*JoinResponse) GetMsg 

func (x *JoinResponse) GetMsg() string

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) ProtoReflect 

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

func (*JoinResponse) Reset 

func (x *JoinResponse) Reset()

func (*JoinResponse) String 

func (x *JoinResponse) String() string

type LeaveRequest 

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

func (*LeaveRequest) Descriptor deprecated 

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

Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) ProtoReflect 

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

func (*LeaveRequest) Reset 

func (x *LeaveRequest) Reset()

func (*LeaveRequest) String 

func (x *LeaveRequest) String() string

type LeaveResponse 

type LeaveResponse struct {
	Msg    string      `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code   string      `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Secret *NodeSecret `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveResponse) Descriptor deprecated 

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

Deprecated: Use LeaveResponse.ProtoReflect.Descriptor instead.

func (*LeaveResponse) GetCode 

func (x *LeaveResponse) GetCode() string

func (*LeaveResponse) GetMsg 

func (x *LeaveResponse) GetMsg() string

func (*LeaveResponse) GetSecret 

func (x *LeaveResponse) GetSecret() *NodeSecret

func (*LeaveResponse) ProtoMessage 

func (*LeaveResponse) ProtoMessage()

func (*LeaveResponse) ProtoReflect 

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

func (*LeaveResponse) Reset 

func (x *LeaveResponse) Reset()

func (*LeaveResponse) String 

func (x *LeaveResponse) String() string

type ListRequest 

type ListRequest struct {
	Secret *NodeSecret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetSecret 

func (x *ListRequest) GetSecret() *NodeSecret

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Msg     string      `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code    string      `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Info    []*NodeInfo `protobuf:"bytes,3,rep,name=info,proto3" json:"info,omitempty"`
	Cluster string      `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetCluster 

func (x *ListResponse) GetCluster() string

func (*ListResponse) GetCode 

func (x *ListResponse) GetCode() string

func (*ListResponse) GetInfo 

func (x *ListResponse) GetInfo() []*NodeInfo

func (*ListResponse) GetMsg 

func (x *ListResponse) GetMsg() string

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type MasterDispatcherClient 

type MasterDispatcherClient interface {
	Listen(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (MasterDispatcher_ListenClient, error)
}

MasterDispatcherClient is the client API for MasterDispatcher 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 NewMasterDispatcherClient 

func NewMasterDispatcherClient(cc grpc.ClientConnInterface) MasterDispatcherClient

type MasterDispatcherServer 

type MasterDispatcherServer interface {
	Listen(*EmptyRequest, MasterDispatcher_ListenServer) error
	// contains filtered or unexported methods
}

MasterDispatcherServer is the server API for MasterDispatcher service. All implementations must embed UnimplementedMasterDispatcherServer for forward compatibility

type MasterDispatcher_ListenClient 

type MasterDispatcher_ListenClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type MasterDispatcher_ListenServer 

type MasterDispatcher_ListenServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type NodeInfo 

type NodeInfo struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Peer   []string `protobuf:"bytes,2,rep,name=peer,proto3" json:"peer,omitempty"`
	Admin  []string `protobuf:"bytes,3,rep,name=admin,proto3" json:"admin,omitempty"`
	Server []string `protobuf:"bytes,4,rep,name=server,proto3" json:"server,omitempty"`
	Leader bool     `protobuf:"varint,5,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAdmin 

func (x *NodeInfo) GetAdmin() []string

func (*NodeInfo) GetLeader 

func (x *NodeInfo) GetLeader() bool

func (*NodeInfo) GetName 

func (x *NodeInfo) GetName() string

func (*NodeInfo) GetPeer 

func (x *NodeInfo) GetPeer() []string

func (*NodeInfo) GetServer 

func (x *NodeInfo) GetServer() []string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type NodeSecret 

type NodeSecret struct {
	NodeKey string `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"`
	NodeID  uint64 `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeSecret) Descriptor deprecated 

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

Deprecated: Use NodeSecret.ProtoReflect.Descriptor instead.

func (*NodeSecret) GetNodeID 

func (x *NodeSecret) GetNodeID() uint64

func (*NodeSecret) GetNodeKey 

func (x *NodeSecret) GetNodeKey() string

func (*NodeSecret) ProtoMessage 

func (*NodeSecret) ProtoMessage()

func (*NodeSecret) ProtoReflect 

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

func (*NodeSecret) Reset 

func (x *NodeSecret) Reset()

func (*NodeSecret) String 

func (x *NodeSecret) String() string

type Plugin 

type Plugin struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // {group}:{project}:{name}
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group   string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Project string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	Render  string `protobuf:"bytes,5,opt,name=render,proto3" json:"render,omitempty"`
	// contains filtered or unexported fields
}

func (*Plugin) Descriptor deprecated 

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

Deprecated: Use Plugin.ProtoReflect.Descriptor instead.

func (*Plugin) GetGroup 

func (x *Plugin) GetGroup() string

func (*Plugin) GetId 

func (x *Plugin) GetId() string

func (*Plugin) GetName 

func (x *Plugin) GetName() string

func (*Plugin) GetProject 

func (x *Plugin) GetProject() string

func (*Plugin) GetRender 

func (x *Plugin) GetRender() string

func (*Plugin) ProtoMessage 

func (*Plugin) ProtoMessage()

func (*Plugin) ProtoReflect 

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

func (*Plugin) Reset 

func (x *Plugin) Reset()

func (*Plugin) String 

func (x *Plugin) String() string

type ProcessLoadArg 

type ProcessLoadArg struct {
	Traffic    []*traffic.PbTraffic `protobuf:"bytes,1,rep,name=traffic,proto3" json:"traffic,omitempty"`
	ListensMsg config.ListenUrl     `protobuf:"bytes,2,opt,name=listensMsg,proto3" json:"listensMsg,omitempty"`
	Extends    map[string]string    `` /* 155-byte string literal not displayed */
	Cluster    etcd.Info
}

type RemoveRequest 

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

func (*RemoveRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetId 

func (x *RemoveRequest) GetId() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

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

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type RemoveResponse 

type RemoveResponse struct {
	Msg  string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResponse) Descriptor deprecated 

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

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) GetCode 

func (x *RemoveResponse) GetCode() string

func (*RemoveResponse) GetMsg 

func (x *RemoveResponse) GetMsg() string

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect 

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

func (*RemoveResponse) Reset 

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String 

func (x *RemoveResponse) String() string

type StatusCode 

type StatusCode int32
const (
	StatusCode_SUCCESS StatusCode = 0
	StatusCode_FAIL    StatusCode = 1
	StatusCode_SKILL   StatusCode = 2
)

func (StatusCode) Descriptor 

func (StatusCode) Descriptor() protoreflect.EnumDescriptor

func (StatusCode) Enum 

func (x StatusCode) Enum() *StatusCode

func (StatusCode) EnumDescriptor deprecated 

func (StatusCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatusCode.Descriptor instead.

func (StatusCode) Number 

func (x StatusCode) Number() protoreflect.EnumNumber

func (StatusCode) String 

func (x StatusCode) String() string

func (StatusCode) Type 

func (StatusCode) Type() protoreflect.EnumType

type UnimplementedCtiServiceServer 

type UnimplementedCtiServiceServer struct {
}

UnimplementedCtiServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCtiServiceServer) Info 

func (UnimplementedCtiServiceServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (UnimplementedCtiServiceServer) Join 

func (UnimplementedCtiServiceServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)

func (UnimplementedCtiServiceServer) Leave 

func (UnimplementedCtiServiceServer) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)

func (UnimplementedCtiServiceServer) List 

func (UnimplementedCtiServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedCtiServiceServer) Remove 

func (UnimplementedCtiServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

type UnimplementedMasterDispatcherServer 

type UnimplementedMasterDispatcherServer struct {
}

UnimplementedMasterDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedMasterDispatcherServer) Listen 

func (UnimplementedMasterDispatcherServer) Listen(*EmptyRequest, MasterDispatcher_ListenServer) error

type UnsafeCtiServiceServer 

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

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

type UnsafeMasterDispatcherServer 

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

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

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.