Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

service

package

Go to main page

Versions in this module

v1

v1.15.7

Feb 3, 2024

v1.15.6

Jan 31, 2024

v1.15.5

Jan 31, 2024

v1.15.4

Jan 30, 2024

v1.15.3

Jan 16, 2024

v1.15.2

Jan 10, 2024

Changes in this version

+ var CtiService_ServiceDesc = grpc.ServiceDesc

+ var File_ctl_proto protoreflect.FileDescriptor

+ var File_event_proto protoreflect.FileDescriptor

+ var File_extender_proto protoreflect.FileDescriptor

+ var File_master_proto protoreflect.FileDescriptor

+ var File_status_proto protoreflect.FileDescriptor

+ var MasterDispatcher_ServiceDesc = grpc.ServiceDesc

+ var StatusCode_name = map[int32]string

+ var StatusCode_value = map[string]int32

+ func RegisterCtiServiceServer(s grpc.ServiceRegistrar, srv CtiServiceServer)

+ func RegisterMasterDispatcherServer(s grpc.ServiceRegistrar, srv MasterDispatcherServer)

+ func ServerAddr(pid int, name string) string

+ func ServerUnixAddr(pid int, name string) string

+ type CtiServiceClient interface

+ Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ Join func(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)

+ Leave func(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

+ Remove func(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)

+ func NewCtiServiceClient(cc grpc.ClientConnInterface) CtiServiceClient

+ type CtiServiceServer interface

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

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

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

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

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

+ type EmptyRequest struct

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

+ func (*EmptyRequest) ProtoMessage()

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

+ func (x *EmptyRequest) Reset()

+ func (x *EmptyRequest) String() string

+ type EnvConfig struct

+ Key string

+ Value string

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

+ func (*EnvConfig) ProtoMessage()

+ func (x *EnvConfig) GetKey() string

+ func (x *EnvConfig) GetValue() string

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

+ func (x *EnvConfig) Reset()

+ func (x *EnvConfig) String() string

+ type Event struct

+ Command string

+ Data []byte

+ Key string

+ Namespace string

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

+ func (*Event) ProtoMessage()

+ func (x *Event) GetCommand() string

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

+ func (x *Event) GetKey() string

+ func (x *Event) GetNamespace() string

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

+ func (x *Event) Reset()

+ func (x *Event) String() string

+ type ExtendsBasicInfo struct

+ Group string

+ Msg string

+ Name string

+ Project string

+ Version string

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

+ func (*ExtendsBasicInfo) ProtoMessage()

+ func (x *ExtendsBasicInfo) GetGroup() string

+ func (x *ExtendsBasicInfo) GetMsg() string

+ func (x *ExtendsBasicInfo) GetName() string

+ func (x *ExtendsBasicInfo) GetProject() string

+ func (x *ExtendsBasicInfo) GetVersion() string

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

+ func (x *ExtendsBasicInfo) Reset()

+ func (x *ExtendsBasicInfo) String() string

+ type ExtendsInfo struct

+ Group string

+ Id string

+ Name string

+ Plugins []*Plugin

+ Project string

+ Version string

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

+ func (*ExtendsInfo) ProtoMessage()

+ func (x *ExtendsInfo) GetGroup() string

+ func (x *ExtendsInfo) GetId() string

+ func (x *ExtendsInfo) GetName() string

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

+ func (x *ExtendsInfo) GetProject() string

+ func (x *ExtendsInfo) GetVersion() string

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

+ func (x *ExtendsInfo) Reset()

+ func (x *ExtendsInfo) String() string

+ type ExtendsInstallRequest struct

+ Extends []*ExtendsBasicInfo

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

+ func (*ExtendsInstallRequest) ProtoMessage()

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

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

+ func (x *ExtendsInstallRequest) Reset()

+ func (x *ExtendsInstallRequest) String() string

+ type ExtendsRequest struct

+ Extends []*ExtendsBasicInfo

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

+ func (*ExtendsRequest) ProtoMessage()

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

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

+ func (x *ExtendsRequest) Reset()

+ func (x *ExtendsRequest) String() string

+ type ExtendsResponse struct

+ Code string

+ Extends []*ExtendsInfo

+ FailExtends []*ExtendsBasicInfo

+ Msg string

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

+ func (*ExtendsResponse) ProtoMessage()

+ func (x *ExtendsResponse) GetCode() string

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

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

+ func (x *ExtendsResponse) GetMsg() string

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

+ func (x *ExtendsResponse) Reset()

+ func (x *ExtendsResponse) String() string

+ type ExtendsUninstallResponse struct

+ Code string

+ Extends []*ExtendsBasicInfo

+ FailExtends []*ExtendsBasicInfo

+ Msg string

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

+ func (*ExtendsUninstallResponse) ProtoMessage()

+ func (x *ExtendsUninstallResponse) GetCode() string

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

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

+ func (x *ExtendsUninstallResponse) GetMsg() string

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

+ func (x *ExtendsUninstallResponse) Reset()

+ func (x *ExtendsUninstallResponse) String() string

+ type ExtendsUpdateRequest struct

+ Extends []*ExtendsBasicInfo

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

+ func (*ExtendsUpdateRequest) ProtoMessage()

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

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

+ func (x *ExtendsUpdateRequest) Reset()

+ func (x *ExtendsUpdateRequest) String() string

+ type IExtenderPluginSetting interface

+ GetPlugin func(pluginID string) (*Plugin, error)

+ Plugins func(extenderName string) ([]*Plugin, error)

+ type IExtenderSetting interface

+ Del func(extenderName string) (*ExtendsInfo, error)

+ List func(sortItem string, desc bool) ([]*ExtendsInfo, error)

+ Reset func(data []*ExtendsInfo) error

+ Save func(extenderName string, data *ExtendsInfo) error

+ type InfoRequest struct

+ Secret *NodeSecret

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

+ func (*InfoRequest) ProtoMessage()

+ func (x *InfoRequest) GetSecret() *NodeSecret

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

+ func (x *InfoRequest) Reset()

+ func (x *InfoRequest) String() string

+ type InfoResponse struct

+ Cluster string

+ Code string

+ Info *NodeInfo

+ Msg string

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

+ func (*InfoResponse) ProtoMessage()

+ func (x *InfoResponse) GetCluster() string

+ func (x *InfoResponse) GetCode() string

+ func (x *InfoResponse) GetInfo() *NodeInfo

+ func (x *InfoResponse) GetMsg() string

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

+ func (x *InfoResponse) Reset()

+ func (x *InfoResponse) String() string

+ type JoinRequest struct

+ ClusterAddress []string

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

+ func (*JoinRequest) ProtoMessage()

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

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

+ func (x *JoinRequest) Reset()

+ func (x *JoinRequest) String() string

+ type JoinResponse struct

+ Code string

+ Info *NodeSecret

+ Msg string

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

+ func (*JoinResponse) ProtoMessage()

+ func (x *JoinResponse) GetCode() string

+ func (x *JoinResponse) GetInfo() *NodeSecret

+ func (x *JoinResponse) GetMsg() string

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

+ func (x *JoinResponse) Reset()

+ func (x *JoinResponse) String() string

+ type LeaveRequest struct

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

+ func (*LeaveRequest) ProtoMessage()

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

+ func (x *LeaveRequest) Reset()

+ func (x *LeaveRequest) String() string

+ type LeaveResponse struct

+ Code string

+ Msg string

+ Secret *NodeSecret

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

+ func (*LeaveResponse) ProtoMessage()

+ func (x *LeaveResponse) GetCode() string

+ func (x *LeaveResponse) GetMsg() string

+ func (x *LeaveResponse) GetSecret() *NodeSecret

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

+ func (x *LeaveResponse) Reset()

+ func (x *LeaveResponse) String() string

+ type ListRequest struct

+ Secret *NodeSecret

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

+ func (*ListRequest) ProtoMessage()

+ func (x *ListRequest) GetSecret() *NodeSecret

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

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ type ListResponse struct

+ Cluster string

+ Code string

+ Info []*NodeInfo

+ Msg string

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

+ func (*ListResponse) ProtoMessage()

+ func (x *ListResponse) GetCluster() string

+ func (x *ListResponse) GetCode() string

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

+ func (x *ListResponse) GetMsg() string

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

+ func (x *ListResponse) Reset()

+ func (x *ListResponse) String() string

+ type MasterDispatcherClient interface

+ Listen func(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (MasterDispatcher_ListenClient, error)

+ func NewMasterDispatcherClient(cc grpc.ClientConnInterface) MasterDispatcherClient

+ type MasterDispatcherServer interface

+ Listen func(*EmptyRequest, MasterDispatcher_ListenServer) error

+ type MasterDispatcher_ListenClient interface

+ Recv func() (*Event, error)

+ type MasterDispatcher_ListenServer interface

+ Send func(*Event) error

+ type NodeInfo struct

+ Admin []string

+ Leader bool

+ Name string

+ Peer []string

+ Server []string

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

+ func (*NodeInfo) ProtoMessage()

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

+ func (x *NodeInfo) GetLeader() bool

+ func (x *NodeInfo) GetName() string

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

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

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

+ func (x *NodeInfo) Reset()

+ func (x *NodeInfo) String() string

+ type NodeSecret struct

+ NodeID uint64

+ NodeKey string

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

+ func (*NodeSecret) ProtoMessage()

+ func (x *NodeSecret) GetNodeID() uint64

+ func (x *NodeSecret) GetNodeKey() string

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

+ func (x *NodeSecret) Reset()

+ func (x *NodeSecret) String() string

+ type Plugin struct

+ Group string

+ Id string

+ Name string

+ Project string

+ Render string

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

+ func (*Plugin) ProtoMessage()

+ func (x *Plugin) GetGroup() string

+ func (x *Plugin) GetId() string

+ func (x *Plugin) GetName() string

+ func (x *Plugin) GetProject() string

+ func (x *Plugin) GetRender() string

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

+ func (x *Plugin) Reset()

+ func (x *Plugin) String() string

+ type ProcessLoadArg struct

+ Cluster etcd.Info

+ Extends map[string]string

+ ListensMsg config.ListenUrl

+ Traffic []*traffic.PbTraffic

+ type RemoveRequest struct

+ Id string

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

+ func (*RemoveRequest) ProtoMessage()

+ func (x *RemoveRequest) GetId() string

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

+ func (x *RemoveRequest) Reset()

+ func (x *RemoveRequest) String() string

+ type RemoveResponse struct

+ Code string

+ Msg string

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

+ func (*RemoveResponse) ProtoMessage()

+ func (x *RemoveResponse) GetCode() string

+ func (x *RemoveResponse) GetMsg() string

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

+ func (x *RemoveResponse) Reset()

+ func (x *RemoveResponse) String() string

+ type StatusCode int32

+ const StatusCode_FAIL

+ const StatusCode_SKILL

+ const StatusCode_SUCCESS

+ func (StatusCode) Descriptor() protoreflect.EnumDescriptor

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

+ func (StatusCode) Type() protoreflect.EnumType

+ func (x StatusCode) Enum() *StatusCode

+ func (x StatusCode) Number() protoreflect.EnumNumber

+ func (x StatusCode) String() string

+ type UnimplementedCtiServiceServer struct

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

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

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

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

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

+ type UnimplementedMasterDispatcherServer struct

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

+ type UnsafeCtiServiceServer interface

+ type UnsafeMasterDispatcherServer interface