service

type GetLinksResp ¶

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

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

func (*GetLinksResp) ProtoMessage()

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

func (x *GetLinksResp) Reset()

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

func (x *GetLinksResp) String() string

type GetLinksResp_builder ¶ added in v0.3.8

type GetLinksResp_builder struct {
	Links map[string]*subscribe.Link
	// contains filtered or unexported fields
}

func (b0 GetLinksResp_builder) Build() *GetLinksResp

type LinkReq ¶

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

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

func (*LinkReq) ProtoMessage()

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

func (x *LinkReq) Reset()

func (x *LinkReq) SetNames(v []string)

func (x *LinkReq) String() string

type LinkReq_builder ¶ added in v0.3.8

type LinkReq_builder struct {
	Names []string
	// contains filtered or unexported fields
}

func (b0 LinkReq_builder) Build() *LinkReq

type NodeClient ¶

type NodeClient interface {
	Now(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NowResp, 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)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodesResponse, 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(cc grpc.ClientConnInterface) NodeClient

type NodeServer ¶

type NodeServer interface {
	Now(context.Context, *emptypb.Empty) (*NowResp, 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)
	List(context.Context, *emptypb.Empty) (*NodesResponse, 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 NodesResponse ¶ added in v0.3.8

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

func (x *NodesResponse) GetGroups() map[string]*node.Nodes

func (*NodesResponse) ProtoMessage()

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

func (x *NodesResponse) Reset()

func (x *NodesResponse) SetGroups(v map[string]*node.Nodes)

func (x *NodesResponse) String() string

type NodesResponse_builder ¶ added in v0.3.8

type NodesResponse_builder struct {
	Groups map[string]*node.Nodes
	// contains filtered or unexported fields
}

func (b0 NodesResponse_builder) Build() *NodesResponse

type NowResp ¶

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

func (x *NowResp) ClearTcp()

func (x *NowResp) ClearUdp()

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

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

func (x *NowResp) HasTcp() bool

func (x *NowResp) HasUdp() bool

func (*NowResp) ProtoMessage()

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

func (x *NowResp) Reset()

func (x *NowResp) SetTcp(v *point.Point)

func (x *NowResp) SetUdp(v *point.Point)

func (x *NowResp) String() string

type NowResp_builder ¶ added in v0.3.8

type NowResp_builder struct {
	Tcp *point.Point
	Udp *point.Point
	// contains filtered or unexported fields
}

func (b0 NowResp_builder) Build() *NowResp

type SaveLinkReq ¶

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

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

func (*SaveLinkReq) ProtoMessage()

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

func (x *SaveLinkReq) Reset()

func (x *SaveLinkReq) SetLinks(v []*subscribe.Link)

func (x *SaveLinkReq) String() string

type SaveLinkReq_builder ¶ added in v0.3.8

type SaveLinkReq_builder struct {
	Links []*subscribe.Link
	// contains filtered or unexported fields
}

func (b0 SaveLinkReq_builder) Build() *SaveLinkReq

type SaveTagReq ¶

type SaveTagReq struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (x *SaveTagReq) ClearHash()

func (x *SaveTagReq) ClearTag()

func (x *SaveTagReq) ClearType()

func (x *SaveTagReq) GetHash() string

func (x *SaveTagReq) GetTag() string

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

func (x *SaveTagReq) HasHash() bool

func (x *SaveTagReq) HasTag() bool

func (x *SaveTagReq) HasType() bool

func (*SaveTagReq) ProtoMessage()

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

func (x *SaveTagReq) Reset()

func (x *SaveTagReq) SetHash(v string)

func (x *SaveTagReq) SetTag(v string)

func (x *SaveTagReq) SetType(v tag.TagType)

func (x *SaveTagReq) String() string

type SaveTagReq_builder ¶ added in v0.3.8

type SaveTagReq_builder struct {
	Tag  *string
	Type *tag.TagType
	Hash *string
	// contains filtered or unexported fields
}

func (b0 SaveTagReq_builder) Build() *SaveTagReq

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(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 TagClient ¶

type TagClient interface {
	Save(ctx context.Context, in *SaveTagReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Remove(ctx context.Context, in *wrapperspb.StringValue, opts ...grpc.CallOption) (*emptypb.Empty, error)
	List(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TagsResponse, error)
}

TagClient is the client API for Tag 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 NewTagClient(cc grpc.ClientConnInterface) TagClient

type TagServer ¶

type TagServer interface {
	Save(context.Context, *SaveTagReq) (*emptypb.Empty, error)
	Remove(context.Context, *wrapperspb.StringValue) (*emptypb.Empty, error)
	List(context.Context, *emptypb.Empty) (*TagsResponse, error)
	// contains filtered or unexported methods
}

TagServer is the server API for Tag service. All implementations must embed UnimplementedTagServer for forward compatibility.

type TagsResponse ¶ added in v0.3.8

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

func (x *TagsResponse) GetTags() map[string]*tag.Tags

func (*TagsResponse) ProtoMessage()

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

func (x *TagsResponse) Reset()

func (x *TagsResponse) SetTags(v map[string]*tag.Tags)

func (x *TagsResponse) String() string

type TagsResponse_builder ¶ added in v0.3.8

type TagsResponse_builder struct {
	Tags map[string]*tag.Tags
	// contains filtered or unexported fields
}

func (b0 TagsResponse_builder) Build() *TagsResponse

type UnimplementedNodeServer ¶

type UnimplementedNodeServer struct{}

UnimplementedNodeServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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

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

func (UnimplementedNodeServer) List(context.Context, *emptypb.Empty) (*NodesResponse, 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 ¶

type UnimplementedSubscribeServer struct{}

UnimplementedSubscribeServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

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 ¶

type UnimplementedTagServer struct{}

UnimplementedTagServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTagServer) List(context.Context, *emptypb.Empty) (*TagsResponse, error)

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

func (UnimplementedTagServer) Save(context.Context, *SaveTagReq) (*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 UnsafeTagServer ¶

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

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

type UseReq ¶

type UseReq struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (x *UseReq) ClearHash()

func (x *UseReq) ClearTcp()

func (x *UseReq) ClearUdp()

func (x *UseReq) GetHash() string

func (x *UseReq) GetTcp() bool

func (x *UseReq) GetUdp() bool

func (x *UseReq) HasHash() bool

func (x *UseReq) HasTcp() bool

func (x *UseReq) HasUdp() bool

func (*UseReq) ProtoMessage()

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

func (x *UseReq) Reset()

func (x *UseReq) SetHash(v string)

func (x *UseReq) SetTcp(v bool)

func (x *UseReq) SetUdp(v bool)

func (x *UseReq) String() string

type UseReq_builder ¶ added in v0.3.8

type UseReq_builder struct {
	Tcp  *bool
	Udp  *bool
	Hash *string
	// contains filtered or unexported fields
}

func (b0 UseReq_builder) Build() *UseReq