service

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Aug 3, 2022 License: Apache-2.0 Imports: 12 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,
		},
	},
	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_process_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 added in v0.5.0 

func RegisterMasterDispatcherServer(s grpc.ServiceRegistrar, srv MasterDispatcherServer)

func ServerAddr added in v0.5.0 

func ServerAddr(pid int, name string) string

func ServerUnixAddr added in v0.5.0 

func ServerUnixAddr(pid int, name string) string

Types

type ClusterRequest 

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

func (*ClusterRequest) Descriptor deprecated 

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

Deprecated: Use ClusterRequest.ProtoReflect.Descriptor instead.

func (*ClusterRequest) ProtoMessage 

func (*ClusterRequest) ProtoMessage()

func (*ClusterRequest) ProtoReflect 

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

func (*ClusterRequest) Reset 

func (x *ClusterRequest) Reset()

func (*ClusterRequest) String 

func (x *ClusterRequest) String() string

type ClusterResponse 

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

func (*ClusterResponse) Descriptor deprecated 

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

Deprecated: Use ClusterResponse.ProtoReflect.Descriptor instead.

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) ProtoReflect 

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

func (*ClusterResponse) Reset 

func (x *ClusterResponse) Reset()

func (*ClusterResponse) String 

func (x *ClusterResponse) String() string

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

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)
	// contains filtered or unexported methods
}

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

type EmptyRequest added in v0.5.0 

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

func (*EmptyRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage added in v0.5.0 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect added in v0.5.0 

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

func (*EmptyRequest) Reset added in v0.5.0 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String added in v0.5.0 

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 added in v0.5.0 

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 added in v0.5.0 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetCommand added in v0.5.0 

func (x *Event) GetCommand() string

func (*Event) GetData added in v0.5.0 

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

func (*Event) GetKey added in v0.5.0 

func (x *Event) GetKey() string

func (*Event) GetNamespace added in v0.5.0 

func (x *Event) GetNamespace() string

func (*Event) ProtoMessage added in v0.5.0 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.5.0 

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

func (*Event) Reset added in v0.5.0 

func (x *Event) Reset()

func (*Event) String added in v0.5.0 

func (x *Event) String() string

type ExtendsBasicInfo added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use ExtendsBasicInfo.ProtoReflect.Descriptor instead.

func (*ExtendsBasicInfo) GetGroup added in v0.3.0 

func (x *ExtendsBasicInfo) GetGroup() string

func (*ExtendsBasicInfo) GetMsg added in v0.3.3 

func (x *ExtendsBasicInfo) GetMsg() string

func (*ExtendsBasicInfo) GetName added in v0.5.0 

func (x *ExtendsBasicInfo) GetName() string

func (*ExtendsBasicInfo) GetProject added in v0.3.0 

func (x *ExtendsBasicInfo) GetProject() string

func (*ExtendsBasicInfo) GetVersion added in v0.3.0 

func (x *ExtendsBasicInfo) GetVersion() string

func (*ExtendsBasicInfo) ProtoMessage added in v0.3.0 

func (*ExtendsBasicInfo) ProtoMessage()

func (*ExtendsBasicInfo) ProtoReflect added in v0.3.0 

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

func (*ExtendsBasicInfo) Reset added in v0.3.0 

func (x *ExtendsBasicInfo) Reset()

func (*ExtendsBasicInfo) String added in v0.3.0 

func (x *ExtendsBasicInfo) String() string

type ExtendsInfo added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use ExtendsInfo.ProtoReflect.Descriptor instead.

func (*ExtendsInfo) GetGroup added in v0.3.0 

func (x *ExtendsInfo) GetGroup() string

func (*ExtendsInfo) GetId added in v0.3.0 

func (x *ExtendsInfo) GetId() string

func (*ExtendsInfo) GetName added in v0.3.0 

func (x *ExtendsInfo) GetName() string

func (*ExtendsInfo) GetPlugins added in v0.3.0 

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

func (*ExtendsInfo) GetProject added in v0.3.0 

func (x *ExtendsInfo) GetProject() string

func (*ExtendsInfo) GetVersion added in v0.3.0 

func (x *ExtendsInfo) GetVersion() string

func (*ExtendsInfo) ProtoMessage added in v0.3.0 

func (*ExtendsInfo) ProtoMessage()

func (*ExtendsInfo) ProtoReflect added in v0.3.0 

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

func (*ExtendsInfo) Reset added in v0.3.0 

func (x *ExtendsInfo) Reset()

func (*ExtendsInfo) String added in v0.3.0 

func (x *ExtendsInfo) String() string

type ExtendsInstallRequest added in v0.3.0 

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

func (*ExtendsInstallRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsInstallRequest.ProtoReflect.Descriptor instead.

func (*ExtendsInstallRequest) GetExtends added in v0.3.0 

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

func (*ExtendsInstallRequest) ProtoMessage added in v0.3.0 

func (*ExtendsInstallRequest) ProtoMessage()

func (*ExtendsInstallRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsInstallRequest) Reset added in v0.3.0 

func (x *ExtendsInstallRequest) Reset()

func (*ExtendsInstallRequest) String added in v0.3.0 

func (x *ExtendsInstallRequest) String() string

type ExtendsRequest added in v0.3.0 

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

func (*ExtendsRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsRequest.ProtoReflect.Descriptor instead.

func (*ExtendsRequest) GetExtends added in v0.3.0 

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

func (*ExtendsRequest) ProtoMessage added in v0.3.0 

func (*ExtendsRequest) ProtoMessage()

func (*ExtendsRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsRequest) Reset added in v0.3.0 

func (x *ExtendsRequest) Reset()

func (*ExtendsRequest) String added in v0.3.0 

func (x *ExtendsRequest) String() string

type ExtendsResponse added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use ExtendsResponse.ProtoReflect.Descriptor instead.

func (*ExtendsResponse) GetCode added in v0.3.0 

func (x *ExtendsResponse) GetCode() string

func (*ExtendsResponse) GetExtends added in v0.3.0 

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

func (*ExtendsResponse) GetFailExtends added in v0.3.3 

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

func (*ExtendsResponse) GetMsg added in v0.3.0 

func (x *ExtendsResponse) GetMsg() string

func (*ExtendsResponse) ProtoMessage added in v0.3.0 

func (*ExtendsResponse) ProtoMessage()

func (*ExtendsResponse) ProtoReflect added in v0.3.0 

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

func (*ExtendsResponse) Reset added in v0.3.0 

func (x *ExtendsResponse) Reset()

func (*ExtendsResponse) String added in v0.3.0 

func (x *ExtendsResponse) String() string

type ExtendsUninstallResponse added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use ExtendsUninstallResponse.ProtoReflect.Descriptor instead.

func (*ExtendsUninstallResponse) GetCode added in v0.3.0 

func (x *ExtendsUninstallResponse) GetCode() string

func (*ExtendsUninstallResponse) GetExtends added in v0.3.0 

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

func (*ExtendsUninstallResponse) GetFailExtends added in v0.3.3 

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

func (*ExtendsUninstallResponse) GetMsg added in v0.3.0 

func (x *ExtendsUninstallResponse) GetMsg() string

func (*ExtendsUninstallResponse) ProtoMessage added in v0.3.0 

func (*ExtendsUninstallResponse) ProtoMessage()

func (*ExtendsUninstallResponse) ProtoReflect added in v0.3.0 

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

func (*ExtendsUninstallResponse) Reset added in v0.3.0 

func (x *ExtendsUninstallResponse) Reset()

func (*ExtendsUninstallResponse) String added in v0.3.0 

func (x *ExtendsUninstallResponse) String() string

type ExtendsUpdateRequest added in v0.3.0 

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

func (*ExtendsUpdateRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsUpdateRequest.ProtoReflect.Descriptor instead.

func (*ExtendsUpdateRequest) GetExtends added in v0.3.0 

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

func (*ExtendsUpdateRequest) ProtoMessage added in v0.3.0 

func (*ExtendsUpdateRequest) ProtoMessage()

func (*ExtendsUpdateRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsUpdateRequest) Reset added in v0.3.0 

func (x *ExtendsUpdateRequest) Reset()

func (*ExtendsUpdateRequest) String added in v0.3.0 

func (x *ExtendsUpdateRequest) String() string

type IExtenderPluginSetting added in v0.5.0 

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

type IExtenderSetting added in v0.5.0 

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,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

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"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

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 added in v0.5.0 

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 added in v0.5.0 

func NewMasterDispatcherClient(cc grpc.ClientConnInterface) MasterDispatcherClient

type MasterDispatcherServer added in v0.5.0 

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 added in v0.5.0 

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

type MasterDispatcher_ListenServer added in v0.5.0 

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

type NodeInfo 

type NodeInfo 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"`
	Term     uint64 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	LeaderID uint64 `protobuf:"varint,4,opt,name=leaderID,proto3" json:"leaderID,omitempty"`
	// status 状态：running | leave | stop | timeout
	Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// role 角色
	RaftState string `protobuf:"bytes,6,opt,name=raftState,proto3" json:"raftState,omitempty"`
	Addr      string `protobuf:"bytes,7,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAddr 

func (x *NodeInfo) GetAddr() string

func (*NodeInfo) GetLeaderID 

func (x *NodeInfo) GetLeaderID() uint64

func (*NodeInfo) GetNodeID 

func (x *NodeInfo) GetNodeID() uint64

func (*NodeInfo) GetNodeKey 

func (x *NodeInfo) GetNodeKey() string

func (*NodeInfo) GetRaftState 

func (x *NodeInfo) GetRaftState() string

func (*NodeInfo) GetStatus 

func (x *NodeInfo) GetStatus() string

func (*NodeInfo) GetTerm 

func (x *NodeInfo) GetTerm() uint64

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 added in v0.3.0 

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 added in v0.3.0 

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

Deprecated: Use Plugin.ProtoReflect.Descriptor instead.

func (*Plugin) GetGroup added in v0.3.0 

func (x *Plugin) GetGroup() string

func (*Plugin) GetId added in v0.3.0 

func (x *Plugin) GetId() string

func (*Plugin) GetName added in v0.3.0 

func (x *Plugin) GetName() string

func (*Plugin) GetProject added in v0.3.0 

func (x *Plugin) GetProject() string

func (*Plugin) GetRender added in v0.5.0 

func (x *Plugin) GetRender() string

func (*Plugin) ProtoMessage added in v0.3.0 

func (*Plugin) ProtoMessage()

func (*Plugin) ProtoReflect added in v0.3.0 

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

func (*Plugin) Reset added in v0.3.0 

func (x *Plugin) Reset()

func (*Plugin) String added in v0.3.0 

func (x *Plugin) String() string

type ProcessLoadArg added in v0.5.0 

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

func (*ProcessLoadArg) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use ProcessLoadArg.ProtoReflect.Descriptor instead.

func (*ProcessLoadArg) GetExtends added in v0.5.0 

func (x *ProcessLoadArg) GetExtends() map[string]string

func (*ProcessLoadArg) GetListensMsg added in v0.5.0 

func (x *ProcessLoadArg) GetListensMsg() *config.ListensMsg

func (*ProcessLoadArg) GetTraffic added in v0.5.0 

func (x *ProcessLoadArg) GetTraffic() []*traffic.PbTraffic

func (*ProcessLoadArg) ProtoMessage added in v0.5.0 

func (*ProcessLoadArg) ProtoMessage()

func (*ProcessLoadArg) ProtoReflect added in v0.5.0 

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

func (*ProcessLoadArg) Reset added in v0.5.0 

func (x *ProcessLoadArg) Reset()

func (*ProcessLoadArg) String added in v0.5.0 

func (x *ProcessLoadArg) String() string

type StatusCode added in v0.5.0 

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

func (StatusCode) Descriptor added in v0.5.0 

func (StatusCode) Descriptor() protoreflect.EnumDescriptor

func (StatusCode) Enum added in v0.5.0 

func (x StatusCode) Enum() *StatusCode

func (StatusCode) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use StatusCode.Descriptor instead.

func (StatusCode) Number added in v0.5.0 

func (x StatusCode) Number() protoreflect.EnumNumber

func (StatusCode) String added in v0.5.0 

func (x StatusCode) String() string

func (StatusCode) Type added in v0.5.0 

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)

type UnimplementedMasterDispatcherServer added in v0.5.0 

type UnimplementedMasterDispatcherServer struct {
}

UnimplementedMasterDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedMasterDispatcherServer) Listen added in v0.5.0 

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 added in v0.5.0 

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.