api

package
v0.0.0-...-d57a918 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2021 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Config_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.api.config",
	HandlerType: (*ConfigServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetConfig",
			Handler:    _Config_GetConfig_Handler,
		},
		{
			MethodName: "SetConfig",
			Handler:    _Config_SetConfig_Handler,
		},
		{
			MethodName: "ReimportRule",
			Handler:    _Config_ReimportRule_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "getRate",
			Handler:       _Config_GetRate_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/api/api.proto",
}

Config_ServiceDesc is the grpc.ServiceDesc for Config 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_internal_api_api_proto protoreflect.FileDescriptor
View Source 
var Node_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.api.Node",
	HandlerType: (*NodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetNodes",
			Handler:    _Node_GetNodes_Handler,
		},
		{
			MethodName: "GetGroup",
			Handler:    _Node_GetGroup_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _Node_GetNode_Handler,
		},
		{
			MethodName: "GetNowGroupAndName",
			Handler:    _Node_GetNowGroupAndName_Handler,
		},
		{
			MethodName: "ChangeNowNode",
			Handler:    _Node_ChangeNowNode_Handler,
		},
		{
			MethodName: "AddNode",
			Handler:    _Node_AddNode_Handler,
		},
		{
			MethodName: "ModifyNode",
			Handler:    _Node_ModifyNode_Handler,
		},
		{
			MethodName: "DeleteNode",
			Handler:    _Node_DeleteNode_Handler,
		},
		{
			MethodName: "Latency",
			Handler:    _Node_Latency_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/api/api.proto",
}

Node_ServiceDesc is the grpc.ServiceDesc for Node 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 ProcessInit_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.api.processInit",
	HandlerType: (*ProcessInitServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateLockFile",
			Handler:    _ProcessInit_CreateLockFile_Handler,
		},
		{
			MethodName: "ProcessInit",
			Handler:    _ProcessInit_ProcessInit_Handler,
		},
		{
			MethodName: "GetRunningHost",
			Handler:    _ProcessInit_GetRunningHost_Handler,
		},
		{
			MethodName: "ClientOn",
			Handler:    _ProcessInit_ClientOn_Handler,
		},
		{
			MethodName: "ProcessExit",
			Handler:    _ProcessInit_ProcessExit_Handler,
		},
		{
			MethodName: "GetKernelPid",
			Handler:    _ProcessInit_GetKernelPid_Handler,
		},
		{
			MethodName: "StopKernel",
			Handler:    _ProcessInit_StopKernel_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SingleInstance",
			Handler:       _ProcessInit_SingleInstance_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "internal/api/api.proto",
}

ProcessInit_ServiceDesc is the grpc.ServiceDesc for ProcessInit 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 Subscribe_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.api.Subscribe",
	HandlerType: (*SubscribeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateSub",
			Handler:    _Subscribe_UpdateSub_Handler,
		},
		{
			MethodName: "GetSubLinks",
			Handler:    _Subscribe_GetSubLinks_Handler,
		},
		{
			MethodName: "AddSubLink",
			Handler:    _Subscribe_AddSubLink_Handler,
		},
		{
			MethodName: "DeleteSubLink",
			Handler:    _Subscribe_DeleteSubLink_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/api/api.proto",
}

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

Functions

func RegisterConfigServer 

func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)

func RegisterNodeServer 

func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

func RegisterProcessInitServer 

func RegisterProcessInitServer(s grpc.ServiceRegistrar, srv ProcessInitServer)

func RegisterSubscribeServer 

func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)

Types

type AllGroupOrNode 

type AllGroupOrNode struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*AllGroupOrNode) Descriptor deprecated 

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

Deprecated: Use AllGroupOrNode.ProtoReflect.Descriptor instead.

func (*AllGroupOrNode) GetValue 

func (x *AllGroupOrNode) GetValue() []string

func (*AllGroupOrNode) ProtoMessage 

func (*AllGroupOrNode) ProtoMessage()

func (*AllGroupOrNode) ProtoReflect 

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

func (*AllGroupOrNode) Reset 

func (x *AllGroupOrNode) Reset()

func (*AllGroupOrNode) String 

func (x *AllGroupOrNode) String() string

type Config 

type Config struct {
	UnimplementedConfigServer
	// contains filtered or unexported fields
}

func (*Config) GetConfig 

func (c *Config) GetConfig(cc context.Context, e *emptypb.Empty) (*config.Setting, error)

func (*Config) GetRate 

func (c *Config) GetRate(_ *emptypb.Empty, srv Config_GetRateServer) error

func (*Config) ReimportRule 

func (c *Config) ReimportRule(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Config) SetConfig 

func (c *Config) SetConfig(cc context.Context, req *config.Setting) (*emptypb.Empty, error)

type ConfigClient 

type ConfigClient interface {
	GetConfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*config.Setting, error)
	SetConfig(ctx context.Context, in *config.Setting, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ReimportRule(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRate(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (Config_GetRateClient, error)
}

ConfigClient is the client API for Config 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 NewConfigClient 

func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient

type ConfigServer 

type ConfigServer interface {
	GetConfig(context.Context, *emptypb.Empty) (*config.Setting, error)
	SetConfig(context.Context, *config.Setting) (*emptypb.Empty, error)
	ReimportRule(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetRate(*emptypb.Empty, Config_GetRateServer) error
	// contains filtered or unexported methods
}

ConfigServer is the server API for Config service. All implementations must embed UnimplementedConfigServer for forward compatibility

func NewConfig 

func NewConfig(e *config.Config, ee *app.ConnManager) ConfigServer

type Config_GetRateClient 

type Config_GetRateClient interface {
	Recv() (*DaUaDrUr, error)
	grpc.ClientStream
}

type Config_GetRateServer 

type Config_GetRateServer interface {
	Send(*DaUaDrUr) error
	grpc.ServerStream
}

type DaUaDrUr 

type DaUaDrUr struct {
	Download string `protobuf:"bytes,1,opt,name=Download,proto3" json:"Download,omitempty"`
	Upload   string `protobuf:"bytes,2,opt,name=Upload,proto3" json:"Upload,omitempty"`
	DownRate string `protobuf:"bytes,3,opt,name=DownRate,proto3" json:"DownRate,omitempty"`
	UpRate   string `protobuf:"bytes,4,opt,name=UpRate,proto3" json:"UpRate,omitempty"`
	// contains filtered or unexported fields
}

func (*DaUaDrUr) Descriptor deprecated 

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

Deprecated: Use DaUaDrUr.ProtoReflect.Descriptor instead.

func (*DaUaDrUr) GetDownRate 

func (x *DaUaDrUr) GetDownRate() string

func (*DaUaDrUr) GetDownload 

func (x *DaUaDrUr) GetDownload() string

func (*DaUaDrUr) GetUpRate 

func (x *DaUaDrUr) GetUpRate() string

func (*DaUaDrUr) GetUpload 

func (x *DaUaDrUr) GetUpload() string

func (*DaUaDrUr) ProtoMessage 

func (*DaUaDrUr) ProtoMessage()

func (*DaUaDrUr) ProtoReflect 

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

func (*DaUaDrUr) Reset 

func (x *DaUaDrUr) Reset()

func (*DaUaDrUr) String 

func (x *DaUaDrUr) String() string

type GroupAndNode 

type GroupAndNode struct {
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Node  string `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupAndNode) Descriptor deprecated 

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

Deprecated: Use GroupAndNode.ProtoReflect.Descriptor instead.

func (*GroupAndNode) GetGroup 

func (x *GroupAndNode) GetGroup() string

func (*GroupAndNode) GetNode 

func (x *GroupAndNode) GetNode() string

func (*GroupAndNode) ProtoMessage 

func (*GroupAndNode) ProtoMessage()

func (*GroupAndNode) ProtoReflect 

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

func (*GroupAndNode) Reset 

func (x *GroupAndNode) Reset()

func (*GroupAndNode) String 

func (x *GroupAndNode) String() string
type Link struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url  string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Link) Descriptor deprecated 

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

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetName 

func (x *Link) GetName() string

func (*Link) GetType 

func (x *Link) GetType() string

func (*Link) GetUrl 

func (x *Link) GetUrl() string

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

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

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) String 

func (x *Link) String() string
type Links struct {
	Value map[string]*Link `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Links) Descriptor deprecated 

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

Deprecated: Use Links.ProtoReflect.Descriptor instead.

func (*Links) GetValue 

func (x *Links) GetValue() map[string]*Link

func (*Links) ProtoMessage 

func (*Links) ProtoMessage()

func (*Links) ProtoReflect 

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

func (*Links) Reset 

func (x *Links) Reset()

func (*Links) String 

func (x *Links) String() string

type Node 

type Node struct {
	UnimplementedNodeServer
	// contains filtered or unexported fields
}

func (*Node) AddNode 

func (n *Node) AddNode(_ context.Context, req *NodeMap) (*emptypb.Empty, error)

func (*Node) ChangeNowNode 

func (n *Node) ChangeNowNode(_ context.Context, req *GroupAndNode) (*emptypb.Empty, error)

func (*Node) DeleteNode 

func (n *Node) DeleteNode(_ context.Context, req *GroupAndNode) (*emptypb.Empty, error)

func (*Node) GetGroup 

func (n *Node) GetGroup(context.Context, *emptypb.Empty) (*AllGroupOrNode, error)

func (*Node) GetNode 

func (n *Node) GetNode(_ context.Context, req *wrapperspb.StringValue) (*AllGroupOrNode, error)

func (*Node) GetNodes 

func (n *Node) GetNodes(context.Context, *emptypb.Empty) (*Nodes, error)

func (*Node) GetNowGroupAndName 

func (n *Node) GetNowGroupAndName(context.Context, *emptypb.Empty) (*GroupAndNode, error)

func (*Node) Latency 

func (n *Node) Latency(_ context.Context, req *GroupAndNode) (*wrapperspb.StringValue, error)

func (*Node) ModifyNode 

func (n *Node) ModifyNode(context.Context, *NodeMap) (*emptypb.Empty, error)

type NodeClient 

type NodeClient interface {
	GetNodes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Nodes, error)
	GetGroup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllGroupOrNode, error)
	GetNode(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*AllGroupOrNode, error)
	GetNowGroupAndName(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GroupAndNode, error)
	ChangeNowNode(ctx context.Context, in *GroupAndNode, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AddNode(ctx context.Context, in *NodeMap, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ModifyNode(ctx context.Context, in *NodeMap, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteNode(ctx context.Context, in *GroupAndNode, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Latency(ctx context.Context, in *GroupAndNode, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
}

NodeClient is the client API for Node 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 NewNodeClient 

func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

type NodeMap 

type NodeMap struct {
	Value map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NodeMap) Descriptor deprecated 

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

Deprecated: Use NodeMap.ProtoReflect.Descriptor instead.

func (*NodeMap) GetValue 

func (x *NodeMap) GetValue() map[string]string

func (*NodeMap) ProtoMessage 

func (*NodeMap) ProtoMessage()

func (*NodeMap) ProtoReflect 

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

func (*NodeMap) Reset 

func (x *NodeMap) Reset()

func (*NodeMap) String 

func (x *NodeMap) String() string

type NodeServer 

type NodeServer interface {
	GetNodes(context.Context, *emptypb.Empty) (*Nodes, error)
	GetGroup(context.Context, *emptypb.Empty) (*AllGroupOrNode, error)
	GetNode(context.Context, *wrapperspb.StringValue) (*AllGroupOrNode, error)
	GetNowGroupAndName(context.Context, *emptypb.Empty) (*GroupAndNode, error)
	ChangeNowNode(context.Context, *GroupAndNode) (*emptypb.Empty, error)
	AddNode(context.Context, *NodeMap) (*emptypb.Empty, error)
	ModifyNode(context.Context, *NodeMap) (*emptypb.Empty, error)
	DeleteNode(context.Context, *GroupAndNode) (*emptypb.Empty, error)
	Latency(context.Context, *GroupAndNode) (*wrapperspb.StringValue, error)
	// contains filtered or unexported methods
}

NodeServer is the server API for Node service. All implementations must embed UnimplementedNodeServer for forward compatibility

func NewNode 

func NewNode(e subscr.NodeManagerServer) NodeServer

type Nodes 

type Nodes struct {
	Value map[string]*AllGroupOrNode `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Nodes) Descriptor deprecated 

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

Deprecated: Use Nodes.ProtoReflect.Descriptor instead.

func (*Nodes) GetValue 

func (x *Nodes) GetValue() map[string]*AllGroupOrNode

func (*Nodes) ProtoMessage 

func (*Nodes) ProtoMessage()

func (*Nodes) ProtoReflect 

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

func (*Nodes) Reset 

func (x *Nodes) Reset()

func (*Nodes) String 

func (x *Nodes) String() string

type Process 

type Process struct {
	UnimplementedProcessInitServer
	// contains filtered or unexported fields
}

func (*Process) ClientOn 

func (s *Process) ClientOn(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Process) CreateLockFile 

func (s *Process) CreateLockFile(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Process) GetKernelPid 

func (s *Process) GetKernelPid(context.Context, *emptypb.Empty) (*wrapperspb.UInt32Value, error)

func (*Process) GetRunningHost 

func (s *Process) GetRunningHost(context.Context, *emptypb.Empty) (*wrapperspb.StringValue, error)

func (*Process) ProcessExit 

func (s *Process) ProcessExit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Process) ProcessInit 

func (s *Process) ProcessInit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Process) SingleInstance 

func (s *Process) SingleInstance(srv ProcessInit_SingleInstanceServer) error

func (*Process) StopKernel 

func (s *Process) StopKernel(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type ProcessInitClient 

type ProcessInitClient interface {
	CreateLockFile(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ProcessInit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetRunningHost(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.StringValue, error)
	ClientOn(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ProcessExit(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetKernelPid(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*wrapperspb.UInt32Value, error)
	StopKernel(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	SingleInstance(ctx context.Context, opts ...grpc.CallOption) (ProcessInit_SingleInstanceClient, error)
}

ProcessInitClient is the client API for ProcessInit 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 NewProcessInitClient 

func NewProcessInitClient(cc grpc.ClientConnInterface) ProcessInitClient

type ProcessInitServer 

type ProcessInitServer interface {
	CreateLockFile(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ProcessInit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetRunningHost(context.Context, *emptypb.Empty) (*wrapperspb.StringValue, error)
	ClientOn(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	ProcessExit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetKernelPid(context.Context, *emptypb.Empty) (*wrapperspb.UInt32Value, error)
	StopKernel(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	SingleInstance(ProcessInit_SingleInstanceServer) error
	// contains filtered or unexported methods
}

ProcessInitServer is the server API for ProcessInit service. All implementations must embed UnimplementedProcessInitServer for forward compatibility

func NewProcess 

func NewProcess(lock *app.Lock, host string) ProcessInitServer

type ProcessInit_SingleInstanceClient 

type ProcessInit_SingleInstanceClient interface {
	Send(*wrapperspb.StringValue) error
	Recv() (*wrapperspb.StringValue, error)
	grpc.ClientStream
}

type ProcessInit_SingleInstanceServer 

type ProcessInit_SingleInstanceServer interface {
	Send(*wrapperspb.StringValue) error
	Recv() (*wrapperspb.StringValue, error)
	grpc.ServerStream
}

type Subscribe 

type Subscribe struct {
	UnimplementedSubscribeServer
	// contains filtered or unexported fields
}
func (s *Subscribe) AddSubLink(ctx context.Context, req *Link) (*Links, error)
func (s *Subscribe) DeleteSubLink(ctx context.Context, req *wrapperspb.StringValue) (*Links, error)
func (s *Subscribe) GetSubLinks(context.Context, *emptypb.Empty) (*Links, error)

func (*Subscribe) UpdateSub 

func (s *Subscribe) UpdateSub(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type SubscribeClient 

type SubscribeClient interface {
	UpdateSub(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetSubLinks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Links, error)
	AddSubLink(ctx context.Context, in *Link, opts ...grpc.CallOption) (*Links, error)
	DeleteSubLink(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*Links, error)
}

SubscribeClient is the client API for Subscribe 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 NewSubscribeClient 

func NewSubscribeClient(cc grpc.ClientConnInterface) SubscribeClient

type SubscribeServer 

type SubscribeServer interface {
	UpdateSub(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	GetSubLinks(context.Context, *emptypb.Empty) (*Links, error)
	AddSubLink(context.Context, *Link) (*Links, error)
	DeleteSubLink(context.Context, *wrapperspb.StringValue) (*Links, error)
	// contains filtered or unexported methods
}

SubscribeServer is the server API for Subscribe service. All implementations must embed UnimplementedSubscribeServer for forward compatibility

func NewSubscribe 

func NewSubscribe(e subscr.NodeManagerServer) SubscribeServer

type UnimplementedConfigServer 

type UnimplementedConfigServer struct {
}

UnimplementedConfigServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigServer) GetConfig 

func (UnimplementedConfigServer) GetConfig(context.Context, *emptypb.Empty) (*config.Setting, error)

func (UnimplementedConfigServer) GetRate 

func (UnimplementedConfigServer) GetRate(*emptypb.Empty, Config_GetRateServer) error

func (UnimplementedConfigServer) ReimportRule 

func (UnimplementedConfigServer) ReimportRule(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedConfigServer) SetConfig 

func (UnimplementedConfigServer) SetConfig(context.Context, *config.Setting) (*emptypb.Empty, error)

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServer) AddNode 

func (UnimplementedNodeServer) AddNode(context.Context, *NodeMap) (*emptypb.Empty, error)

func (UnimplementedNodeServer) ChangeNowNode 

func (UnimplementedNodeServer) ChangeNowNode(context.Context, *GroupAndNode) (*emptypb.Empty, error)

func (UnimplementedNodeServer) DeleteNode 

func (UnimplementedNodeServer) DeleteNode(context.Context, *GroupAndNode) (*emptypb.Empty, error)

func (UnimplementedNodeServer) GetGroup 

func (UnimplementedNodeServer) GetGroup(context.Context, *emptypb.Empty) (*AllGroupOrNode, error)

func (UnimplementedNodeServer) GetNode 

func (UnimplementedNodeServer) GetNode(context.Context, *wrapperspb.StringValue) (*AllGroupOrNode, error)

func (UnimplementedNodeServer) GetNodes 

func (UnimplementedNodeServer) GetNodes(context.Context, *emptypb.Empty) (*Nodes, error)

func (UnimplementedNodeServer) GetNowGroupAndName 

func (UnimplementedNodeServer) GetNowGroupAndName(context.Context, *emptypb.Empty) (*GroupAndNode, error)

func (UnimplementedNodeServer) Latency 

func (UnimplementedNodeServer) Latency(context.Context, *GroupAndNode) (*wrapperspb.StringValue, error)

func (UnimplementedNodeServer) ModifyNode 

func (UnimplementedNodeServer) ModifyNode(context.Context, *NodeMap) (*emptypb.Empty, error)

type UnimplementedProcessInitServer 

type UnimplementedProcessInitServer struct {
}

UnimplementedProcessInitServer must be embedded to have forward compatible implementations.

func (UnimplementedProcessInitServer) ClientOn 

func (UnimplementedProcessInitServer) ClientOn(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcessInitServer) CreateLockFile 

func (UnimplementedProcessInitServer) CreateLockFile(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcessInitServer) GetKernelPid 

func (UnimplementedProcessInitServer) GetKernelPid(context.Context, *emptypb.Empty) (*wrapperspb.UInt32Value, error)

func (UnimplementedProcessInitServer) GetRunningHost 

func (UnimplementedProcessInitServer) GetRunningHost(context.Context, *emptypb.Empty) (*wrapperspb.StringValue, error)

func (UnimplementedProcessInitServer) ProcessExit 

func (UnimplementedProcessInitServer) ProcessExit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcessInitServer) ProcessInit 

func (UnimplementedProcessInitServer) ProcessInit(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedProcessInitServer) SingleInstance 

func (UnimplementedProcessInitServer) SingleInstance(ProcessInit_SingleInstanceServer) error

func (UnimplementedProcessInitServer) StopKernel 

func (UnimplementedProcessInitServer) StopKernel(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnimplementedSubscribeServer 

type UnimplementedSubscribeServer struct {
}

UnimplementedSubscribeServer must be embedded to have forward compatible implementations. 

func (UnimplementedSubscribeServer) AddSubLink(context.Context, *Link) (*Links, error)
func (UnimplementedSubscribeServer) DeleteSubLink(context.Context, *wrapperspb.StringValue) (*Links, error)
func (UnimplementedSubscribeServer) GetSubLinks(context.Context, *emptypb.Empty) (*Links, error)

func (UnimplementedSubscribeServer) UpdateSub 

func (UnimplementedSubscribeServer) UpdateSub(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnsafeConfigServer 

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

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

type UnsafeNodeServer 

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

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

type UnsafeProcessInitServer 

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

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

type UnsafeSubscribeServer 

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

UnsafeSubscribeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscribeServer 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.