service

package
v0.3.1-rc.4 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2022 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NowReqNowReqNet_name = map[int32]string{
		0: "reserve",
		1: "tcp",
		2: "udp",
	}
	NowReqNowReqNet_value = map[string]int32{
		"reserve": 0,
		"tcp":     1,
		"udp":     2,
	}
)

Enum value maps for NowReqNowReqNet.

View Source 
var File_node_grpc_node_proto protoreflect.FileDescriptor
View Source 
var Node_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.protos.node.service.node",
	HandlerType: (*NodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "now",
			Handler:    _Node_Now_Handler,
		},
		{
			MethodName: "use",
			Handler:    _Node_Use_Handler,
		},
		{
			MethodName: "get",
			Handler:    _Node_Get_Handler,
		},
		{
			MethodName: "save",
			Handler:    _Node_Save_Handler,
		},
		{
			MethodName: "remove",
			Handler:    _Node_Remove_Handler,
		},
		{
			MethodName: "manager",
			Handler:    _Node_Manager_Handler,
		},
		{
			MethodName: "latency",
			Handler:    _Node_Latency_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node/grpc/node.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 Subscribe_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yuhaiin.protos.node.service.subscribe",
	HandlerType: (*SubscribeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "save",
			Handler:    _Subscribe_Save_Handler,
		},
		{
			MethodName: "remove",
			Handler:    _Subscribe_Remove_Handler,
		},
		{
			MethodName: "update",
			Handler:    _Subscribe_Update_Handler,
		},
		{
			MethodName: "get",
			Handler:    _Subscribe_Get_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node/grpc/node.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 RegisterNodeServer 

func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

func RegisterSubscribeServer 

func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)

Types

type GetLinksResp 

type GetLinksResp struct {
	Links map[string]*subscribe.Link `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetLinksResp) Descriptor deprecated 

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

Deprecated: Use GetLinksResp.ProtoReflect.Descriptor instead. 

func (x *GetLinksResp) GetLinks() map[string]*subscribe.Link

func (*GetLinksResp) ProtoMessage 

func (*GetLinksResp) ProtoMessage()

func (*GetLinksResp) ProtoReflect 

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

func (*GetLinksResp) Reset 

func (x *GetLinksResp) Reset()

func (*GetLinksResp) String 

func (x *GetLinksResp) String() string

type LinkReq 

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

func (*LinkReq) Descriptor deprecated 

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

Deprecated: Use LinkReq.ProtoReflect.Descriptor instead.

func (*LinkReq) GetNames 

func (x *LinkReq) GetNames() []string

func (*LinkReq) ProtoMessage 

func (*LinkReq) ProtoMessage()

func (*LinkReq) ProtoReflect 

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

func (*LinkReq) Reset 

func (x *LinkReq) Reset()

func (*LinkReq) String 

func (x *LinkReq) String() string

type NodeClient 

type NodeClient interface {
	Now(ctx context.Context, in *NowReq, opts ...grpc.CallOption) (*point.Point, error)
	// use req is hash string of point
	Use(ctx context.Context, in *UseReq, opts ...grpc.CallOption) (*point.Point, error)
	Get(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*point.Point, error)
	Save(ctx context.Context, in *point.Point, opts ...grpc.CallOption) (*point.Point, error)
	Remove(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Manager(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*node.Manager, error)
	Latency(ctx context.Context, in *latency.Requests, opts ...grpc.CallOption) (*latency.Response, 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 NodeServer 

type NodeServer interface {
	Now(context.Context, *NowReq) (*point.Point, error)
	// use req is hash string of point
	Use(context.Context, *UseReq) (*point.Point, error)
	Get(context.Context, *wrapperspb.StringValue) (*point.Point, error)
	Save(context.Context, *point.Point) (*point.Point, error)
	Remove(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
	Manager(context.Context, *wrapperspb.StringValue) (*node.Manager, error)
	Latency(context.Context, *latency.Requests) (*latency.Response, error)
	// contains filtered or unexported methods
}

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

type NowReq 

type NowReq struct {
	Net NowReqNowReqNet `protobuf:"varint,1,opt,name=net,json=type,proto3,enum=yuhaiin.protos.node.service.NowReqNowReqNet" json:"net,omitempty"`
	// contains filtered or unexported fields
}

func (*NowReq) Descriptor deprecated 

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

Deprecated: Use NowReq.ProtoReflect.Descriptor instead.

func (*NowReq) GetNet 

func (x *NowReq) GetNet() NowReqNowReqNet

func (*NowReq) ProtoMessage 

func (*NowReq) ProtoMessage()

func (*NowReq) ProtoReflect 

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

func (*NowReq) Reset 

func (x *NowReq) Reset()

func (*NowReq) String 

func (x *NowReq) String() string

type NowReqNowReqNet 

type NowReqNowReqNet int32
const (
	NowReq_reserve NowReqNowReqNet = 0
	NowReq_tcp     NowReqNowReqNet = 1
	NowReq_udp     NowReqNowReqNet = 2
)

func (NowReqNowReqNet) Descriptor 

func (NowReqNowReqNet) Descriptor() protoreflect.EnumDescriptor

func (NowReqNowReqNet) Enum 

func (x NowReqNowReqNet) Enum() *NowReqNowReqNet

func (NowReqNowReqNet) EnumDescriptor deprecated 

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

Deprecated: Use NowReqNowReqNet.Descriptor instead.

func (NowReqNowReqNet) Number 

func (x NowReqNowReqNet) Number() protoreflect.EnumNumber

func (NowReqNowReqNet) String 

func (x NowReqNowReqNet) String() string

func (NowReqNowReqNet) Type 

func (NowReqNowReqNet) Type() protoreflect.EnumType

type SaveLinkReq 

type SaveLinkReq struct {
	Links []*subscribe.Link `protobuf:"bytes,1,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveLinkReq) Descriptor deprecated 

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

Deprecated: Use SaveLinkReq.ProtoReflect.Descriptor instead. 

func (x *SaveLinkReq) GetLinks() []*subscribe.Link

func (*SaveLinkReq) ProtoMessage 

func (*SaveLinkReq) ProtoMessage()

func (*SaveLinkReq) ProtoReflect 

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

func (*SaveLinkReq) Reset 

func (x *SaveLinkReq) Reset()

func (*SaveLinkReq) String 

func (x *SaveLinkReq) String() string

type SubscribeClient 

type SubscribeClient interface {
	Save(ctx context.Context, in *SaveLinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Remove(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Update(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Get(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLinksResp, 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 {
	Save(context.Context, *SaveLinkReq) (*emptypb.Empty, error)
	Remove(context.Context, *LinkReq) (*emptypb.Empty, error)
	Update(context.Context, *LinkReq) (*emptypb.Empty, error)
	Get(context.Context, *emptypb.Empty) (*GetLinksResp, error)
	// contains filtered or unexported methods
}

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

type UnimplementedNodeServer 

type UnimplementedNodeServer struct {
}

UnimplementedNodeServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServer) Get 

func (UnimplementedNodeServer) Get(context.Context, *wrapperspb.StringValue) (*point.Point, error)

func (UnimplementedNodeServer) Latency 

func (UnimplementedNodeServer) Latency(context.Context, *latency.Requests) (*latency.Response, error)

func (UnimplementedNodeServer) Manager 

func (UnimplementedNodeServer) Manager(context.Context, *wrapperspb.StringValue) (*node.Manager, error)

func (UnimplementedNodeServer) Now 

func (UnimplementedNodeServer) Now(context.Context, *NowReq) (*point.Point, error)

func (UnimplementedNodeServer) Remove 

func (UnimplementedNodeServer) Remove(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)

func (UnimplementedNodeServer) Save 

func (UnimplementedNodeServer) Save(context.Context, *point.Point) (*point.Point, error)

func (UnimplementedNodeServer) Use 

func (UnimplementedNodeServer) Use(context.Context, *UseReq) (*point.Point, error)

type UnimplementedSubscribeServer 

type UnimplementedSubscribeServer struct {
}

UnimplementedSubscribeServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscribeServer) Get 

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

func (UnimplementedSubscribeServer) Remove 

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

func (UnimplementedSubscribeServer) Save 

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

func (UnimplementedSubscribeServer) Update 

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

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 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.

type UseReq 

type UseReq struct {
	Tcp  bool   `protobuf:"varint,1,opt,name=tcp,proto3" json:"tcp,omitempty"`
	Udp  bool   `protobuf:"varint,2,opt,name=udp,proto3" json:"udp,omitempty"`
	Hash string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*UseReq) Descriptor deprecated 

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

Deprecated: Use UseReq.ProtoReflect.Descriptor instead.

func (*UseReq) GetHash 

func (x *UseReq) GetHash() string

func (*UseReq) GetTcp 

func (x *UseReq) GetTcp() bool

func (*UseReq) GetUdp 

func (x *UseReq) GetUdp() bool

func (*UseReq) ProtoMessage 

func (*UseReq) ProtoMessage()

func (*UseReq) ProtoReflect 

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

func (*UseReq) Reset 

func (x *UseReq) Reset()

func (*UseReq) String 

func (x *UseReq) String() string

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.