service

Dec 21, 2023

Changes in this version

+ const Node_Get_FullMethodName

+ const Node_Latency_FullMethodName

+ const Node_Manager_FullMethodName

+ const Node_Now_FullMethodName

+ const Node_Remove_FullMethodName

+ const Node_Save_FullMethodName

+ const Node_Use_FullMethodName

+ const Subscribe_Get_FullMethodName

+ const Subscribe_Remove_FullMethodName

+ const Subscribe_Save_FullMethodName

+ const Subscribe_Update_FullMethodName

+ const Tag_Remove_FullMethodName

+ const Tag_Save_FullMethodName

+ var File_node_grpc_node_proto protoreflect.FileDescriptor

+ var Node_ServiceDesc = grpc.ServiceDesc

+ var Subscribe_ServiceDesc = grpc.ServiceDesc

+ var Tag_ServiceDesc = grpc.ServiceDesc

+ func RegisterNodeServer(s grpc.ServiceRegistrar, srv NodeServer)

+ func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)

+ func RegisterTagServer(s grpc.ServiceRegistrar, srv TagServer)

+ type GetLinksResp struct

+ Links map[string]*subscribe.Link

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

+ func (*GetLinksResp) ProtoMessage()

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

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

+ func (x *GetLinksResp) Reset()

+ func (x *GetLinksResp) String() string

+ type LinkReq struct

+ Names []string

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

+ func (*LinkReq) ProtoMessage()

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

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

+ func (x *LinkReq) Reset()

+ func (x *LinkReq) String() string

+ type NodeClient interface

+ Get func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*point.Point, error)

+ Latency func(ctx context.Context, in *latency.Requests, opts ...grpc.CallOption) (*latency.Response, error)

+ Manager func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*node.Manager, error)

+ Now func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NowResp, error)

+ Remove func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Save func(ctx context.Context, in *point.Point, opts ...grpc.CallOption) (*point.Point, error)

+ Use func(ctx context.Context, in *UseReq, opts ...grpc.CallOption) (*point.Point, error)

+ func NewNodeClient(cc grpc.ClientConnInterface) NodeClient

+ type NodeServer interface

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

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

+ Manager func(context.Context, *emptypb.Empty) (*node.Manager, error)

+ Now func(context.Context, *emptypb.Empty) (*NowResp, error)

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

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

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

+ type NowResp struct

+ Tcp *point.Point

+ Udp *point.Point

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

+ func (*NowResp) ProtoMessage()

+ func (x *NowResp) GetTcp() *point.Point

+ func (x *NowResp) GetUdp() *point.Point

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

+ func (x *NowResp) Reset()

+ func (x *NowResp) String() string

+ type SaveLinkReq struct

+ Links []*subscribe.Link

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

+ func (*SaveLinkReq) ProtoMessage()

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

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

+ func (x *SaveLinkReq) Reset()

+ func (x *SaveLinkReq) String() string

+ type SaveTagReq struct

+ Hash string

+ Tag string

+ Type tag.TagType

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

+ func (*SaveTagReq) ProtoMessage()

+ func (x *SaveTagReq) GetHash() string

+ func (x *SaveTagReq) GetTag() string

+ func (x *SaveTagReq) GetType() tag.TagType

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

+ func (x *SaveTagReq) Reset()

+ func (x *SaveTagReq) String() string

+ type SubscribeClient interface

+ Get func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLinksResp, error)

+ Remove func(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Save func(ctx context.Context, in *SaveLinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Update func(ctx context.Context, in *LinkReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewSubscribeClient(cc grpc.ClientConnInterface) SubscribeClient

+ type SubscribeServer interface

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

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

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

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

+ type TagClient interface

+ Remove func(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Save func(ctx context.Context, in *SaveTagReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewTagClient(cc grpc.ClientConnInterface) TagClient

+ type TagServer interface

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

+ Save func(context.Context, *SaveTagReq) (*emptypb.Empty, error)

+ type UnimplementedNodeServer struct

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

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

+ func (UnimplementedNodeServer) Manager(context.Context, *emptypb.Empty) (*node.Manager, error)

+ func (UnimplementedNodeServer) Now(context.Context, *emptypb.Empty) (*NowResp, error)

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

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

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

+ type UnimplementedSubscribeServer struct

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

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

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

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

+ type UnimplementedTagServer struct

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

+ func (UnimplementedTagServer) Save(context.Context, *SaveTagReq) (*emptypb.Empty, error)

+ type UnsafeNodeServer interface

+ type UnsafeSubscribeServer interface

+ type UnsafeTagServer interface

+ type UseReq struct

+ Hash string

+ Tcp bool

+ Udp bool

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

+ func (*UseReq) ProtoMessage()

+ func (x *UseReq) GetHash() string

+ func (x *UseReq) GetTcp() bool

+ func (x *UseReq) GetUdp() bool

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

+ func (x *UseReq) Reset()

+ func (x *UseReq) String() string