Documentation ¶
Index ¶
- Variables
- func RegisterLinkServiceServer(s grpc.ServiceRegistrar, srv LinkServiceServer)
- type Announce
- func (*Announce) Descriptor() ([]byte, []int)deprecated
- func (x *Announce) GetDeadlineUnixMs() uint64
- func (x *Announce) GetId() uint64
- func (x *Announce) GetName() []byte
- func (x *Announce) GetValue() *Metric
- func (*Announce) ProtoMessage()
- func (x *Announce) ProtoReflect() protoreflect.Message
- func (x *Announce) Reset()
- func (x *Announce) String() string
- type DownData
- type DownFinish
- func (*DownFinish) Descriptor() ([]byte, []int)deprecated
- func (x *DownFinish) GetMessage() string
- func (x *DownFinish) GetMetadata() *MD
- func (x *DownFinish) GetStatus() uint32
- func (*DownFinish) ProtoMessage()
- func (x *DownFinish) ProtoReflect() protoreflect.Message
- func (x *DownFinish) Reset()
- func (x *DownFinish) String() string
- type DownResponse
- type LinkFrame
- func (*LinkFrame) Descriptor() ([]byte, []int)deprecated
- func (x *LinkFrame) GetAnnounce() *Announce
- func (x *LinkFrame) GetQuery() *Query
- func (x *LinkFrame) GetRpcFrame() *RPCFrame
- func (m *LinkFrame) GetType() isLinkFrame_Type
- func (*LinkFrame) ProtoMessage()
- func (x *LinkFrame) ProtoReflect() protoreflect.Message
- func (x *LinkFrame) Reset()
- func (x *LinkFrame) String() string
- type LinkFrame_Announce
- type LinkFrame_Query
- type LinkFrame_RpcFrame
- type LinkServiceClient
- type LinkServiceServer
- type LinkService_LinkClient
- type LinkService_LinkServer
- type MD
- type Metric
- type Query
- type RPCFrame
- func (*RPCFrame) Descriptor() ([]byte, []int)deprecated
- func (x *RPCFrame) GetDownData() *DownData
- func (x *RPCFrame) GetDownFinish() *DownFinish
- func (x *RPCFrame) GetDownResp() *DownResponse
- func (x *RPCFrame) GetId() uint64
- func (m *RPCFrame) GetType() isRPCFrame_Type
- func (x *RPCFrame) GetUpCancel() *UpCancel
- func (x *RPCFrame) GetUpClose() *UpClose
- func (x *RPCFrame) GetUpData() *UpData
- func (x *RPCFrame) GetUpStart() *UpStart
- func (*RPCFrame) ProtoMessage()
- func (x *RPCFrame) ProtoReflect() protoreflect.Message
- func (x *RPCFrame) Reset()
- func (x *RPCFrame) String() string
- type RPCFrame_DownData
- type RPCFrame_DownFinish
- type RPCFrame_DownResp
- type RPCFrame_UpCancel
- type RPCFrame_UpClose
- type RPCFrame_UpData
- type RPCFrame_UpStart
- type UnimplementedLinkServiceServer
- type UnsafeLinkServiceServer
- type UpCancel
- type UpClose
- type UpData
- type UpStart
- func (*UpStart) Descriptor() ([]byte, []int)deprecated
- func (x *UpStart) GetDestinationId() []byte
- func (x *UpStart) GetMetadata() *MD
- func (x *UpStart) GetProperties() map[string][]byte
- func (x *UpStart) GetSourceId() []byte
- func (*UpStart) ProtoMessage()
- func (x *UpStart) ProtoReflect() protoreflect.Message
- func (x *UpStart) Reset()
- func (x *UpStart) String() string
Constants ¶
This section is empty.
Variables ¶
var File_blachris_arpcnet_v1_link_service_proto protoreflect.FileDescriptor
var File_blachris_arpcnet_v1_rpcframe_proto protoreflect.FileDescriptor
var LinkService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "blachris.arpcnet.v1.LinkService", HandlerType: (*LinkServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Link", Handler: _LinkService_Link_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "blachris/arpcnet/v1/link_service.proto", }
LinkService_ServiceDesc is the grpc.ServiceDesc for LinkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterLinkServiceServer ¶
func RegisterLinkServiceServer(s grpc.ServiceRegistrar, srv LinkServiceServer)
Types ¶
type Announce ¶
type Announce struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name []byte `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Value *Metric `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` DeadlineUnixMs uint64 `protobuf:"varint,4,opt,name=deadline_unix_ms,json=deadlineUnixMs,proto3" json:"deadline_unix_ms,omitempty"` // contains filtered or unexported fields }
func (*Announce) Descriptor
deprecated
func (*Announce) GetDeadlineUnixMs ¶
func (*Announce) ProtoMessage ¶
func (*Announce) ProtoMessage()
func (*Announce) ProtoReflect ¶
func (x *Announce) ProtoReflect() protoreflect.Message
type DownData ¶
type DownData struct { Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` Remaining uint32 `protobuf:"varint,2,opt,name=remaining,proto3" json:"remaining,omitempty"` // contains filtered or unexported fields }
func (*DownData) Descriptor
deprecated
func (*DownData) GetRemaining ¶
func (*DownData) ProtoMessage ¶
func (*DownData) ProtoMessage()
func (*DownData) ProtoReflect ¶
func (x *DownData) ProtoReflect() protoreflect.Message
type DownFinish ¶
type DownFinish struct { Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Metadata *MD `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*DownFinish) Descriptor
deprecated
func (*DownFinish) Descriptor() ([]byte, []int)
Deprecated: Use DownFinish.ProtoReflect.Descriptor instead.
func (*DownFinish) GetMessage ¶
func (x *DownFinish) GetMessage() string
func (*DownFinish) GetMetadata ¶
func (x *DownFinish) GetMetadata() *MD
func (*DownFinish) GetStatus ¶
func (x *DownFinish) GetStatus() uint32
func (*DownFinish) ProtoMessage ¶
func (*DownFinish) ProtoMessage()
func (*DownFinish) ProtoReflect ¶
func (x *DownFinish) ProtoReflect() protoreflect.Message
func (*DownFinish) Reset ¶
func (x *DownFinish) Reset()
func (*DownFinish) String ¶
func (x *DownFinish) String() string
type DownResponse ¶
type DownResponse struct { Metadata *MD `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*DownResponse) Descriptor
deprecated
func (*DownResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownResponse.ProtoReflect.Descriptor instead.
func (*DownResponse) GetMetadata ¶
func (x *DownResponse) GetMetadata() *MD
func (*DownResponse) ProtoMessage ¶
func (*DownResponse) ProtoMessage()
func (*DownResponse) ProtoReflect ¶
func (x *DownResponse) ProtoReflect() protoreflect.Message
func (*DownResponse) Reset ¶
func (x *DownResponse) Reset()
func (*DownResponse) String ¶
func (x *DownResponse) String() string
type LinkFrame ¶
type LinkFrame struct { // Types that are assignable to Type: // *LinkFrame_RpcFrame // *LinkFrame_Query // *LinkFrame_Announce Type isLinkFrame_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*LinkFrame) Descriptor
deprecated
func (*LinkFrame) GetAnnounce ¶
func (*LinkFrame) GetRpcFrame ¶
func (*LinkFrame) ProtoMessage ¶
func (*LinkFrame) ProtoMessage()
func (*LinkFrame) ProtoReflect ¶
func (x *LinkFrame) ProtoReflect() protoreflect.Message
type LinkFrame_Announce ¶
type LinkFrame_Announce struct {
Announce *Announce `protobuf:"bytes,3,opt,name=announce,proto3,oneof"`
}
type LinkFrame_Query ¶
type LinkFrame_Query struct {
Query *Query `protobuf:"bytes,2,opt,name=query,proto3,oneof"`
}
type LinkFrame_RpcFrame ¶
type LinkFrame_RpcFrame struct {
RpcFrame *RPCFrame `protobuf:"bytes,1,opt,name=rpc_frame,json=rpcFrame,proto3,oneof"`
}
type LinkServiceClient ¶
type LinkServiceClient interface {
Link(ctx context.Context, opts ...grpc.CallOption) (LinkService_LinkClient, error)
}
LinkServiceClient is the client API for LinkService 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 NewLinkServiceClient ¶
func NewLinkServiceClient(cc grpc.ClientConnInterface) LinkServiceClient
type LinkServiceServer ¶
type LinkServiceServer interface { Link(LinkService_LinkServer) error // contains filtered or unexported methods }
LinkServiceServer is the server API for LinkService service. All implementations must embed UnimplementedLinkServiceServer for forward compatibility
type LinkService_LinkClient ¶
type LinkService_LinkServer ¶
type MD ¶
type MD struct { KvPairs []string `protobuf:"bytes,1,rep,name=kv_pairs,json=kvPairs,proto3" json:"kv_pairs,omitempty"` // contains filtered or unexported fields }
func (*MD) Descriptor
deprecated
func (*MD) GetKvPairs ¶
func (*MD) ProtoMessage ¶
func (*MD) ProtoMessage()
func (*MD) ProtoReflect ¶
func (x *MD) ProtoReflect() protoreflect.Message
type Metric ¶
type Metric struct { Hops int32 `protobuf:"varint,1,opt,name=hops,proto3" json:"hops,omitempty"` // contains filtered or unexported fields }
func (*Metric) Descriptor
deprecated
func (*Metric) ProtoMessage ¶
func (*Metric) ProtoMessage()
func (*Metric) ProtoReflect ¶
func (x *Metric) ProtoReflect() protoreflect.Message
type Query ¶
type Query struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name []byte `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // How long this query is valid in Unix seconds. // Receivers of this message can choose a shorter deadline. DeadlineUnixMs uint64 `protobuf:"varint,3,opt,name=deadline_unix_ms,json=deadlineUnixMs,proto3" json:"deadline_unix_ms,omitempty"` // contains filtered or unexported fields }
func (*Query) Descriptor
deprecated
func (*Query) GetDeadlineUnixMs ¶
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type RPCFrame ¶
type RPCFrame struct { Id uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Type: // *RPCFrame_UpStart // *RPCFrame_UpData // *RPCFrame_UpClose // *RPCFrame_UpCancel // *RPCFrame_DownResp // *RPCFrame_DownData // *RPCFrame_DownFinish Type isRPCFrame_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*RPCFrame) Descriptor
deprecated
func (*RPCFrame) GetDownData ¶
func (*RPCFrame) GetDownFinish ¶
func (x *RPCFrame) GetDownFinish() *DownFinish
func (*RPCFrame) GetDownResp ¶
func (x *RPCFrame) GetDownResp() *DownResponse
func (*RPCFrame) GetUpCancel ¶
func (*RPCFrame) GetUpClose ¶
func (*RPCFrame) GetUpStart ¶
func (*RPCFrame) ProtoMessage ¶
func (*RPCFrame) ProtoMessage()
func (*RPCFrame) ProtoReflect ¶
func (x *RPCFrame) ProtoReflect() protoreflect.Message
type RPCFrame_DownData ¶
type RPCFrame_DownData struct {
DownData *DownData `protobuf:"bytes,9,opt,name=down_data,json=downData,proto3,oneof"`
}
type RPCFrame_DownFinish ¶
type RPCFrame_DownFinish struct {
DownFinish *DownFinish `protobuf:"bytes,10,opt,name=down_finish,json=downFinish,proto3,oneof"`
}
type RPCFrame_DownResp ¶
type RPCFrame_DownResp struct {
DownResp *DownResponse `protobuf:"bytes,8,opt,name=down_resp,json=downResp,proto3,oneof"`
}
type RPCFrame_UpCancel ¶
type RPCFrame_UpCancel struct {
UpCancel *UpCancel `protobuf:"bytes,5,opt,name=up_cancel,json=upCancel,proto3,oneof"`
}
type RPCFrame_UpClose ¶
type RPCFrame_UpClose struct {
UpClose *UpClose `protobuf:"bytes,4,opt,name=up_close,json=upClose,proto3,oneof"`
}
type RPCFrame_UpData ¶
type RPCFrame_UpData struct {
UpData *UpData `protobuf:"bytes,3,opt,name=up_data,json=upData,proto3,oneof"`
}
type RPCFrame_UpStart ¶
type RPCFrame_UpStart struct {
UpStart *UpStart `protobuf:"bytes,2,opt,name=up_start,json=upStart,proto3,oneof"`
}
type UnimplementedLinkServiceServer ¶
type UnimplementedLinkServiceServer struct { }
UnimplementedLinkServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedLinkServiceServer) Link ¶
func (UnimplementedLinkServiceServer) Link(LinkService_LinkServer) error
type UnsafeLinkServiceServer ¶
type UnsafeLinkServiceServer interface {
// contains filtered or unexported methods
}
UnsafeLinkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LinkServiceServer will result in compilation errors.
type UpCancel ¶
type UpCancel struct { Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*UpCancel) Descriptor
deprecated
func (*UpCancel) GetMessage ¶
func (*UpCancel) ProtoMessage ¶
func (*UpCancel) ProtoMessage()
func (*UpCancel) ProtoReflect ¶
func (x *UpCancel) ProtoReflect() protoreflect.Message
type UpClose ¶
type UpClose struct {
// contains filtered or unexported fields
}
func (*UpClose) Descriptor
deprecated
func (*UpClose) ProtoMessage ¶
func (*UpClose) ProtoMessage()
func (*UpClose) ProtoReflect ¶
func (x *UpClose) ProtoReflect() protoreflect.Message
type UpData ¶
type UpData struct { Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` Remaining uint32 `protobuf:"varint,2,opt,name=remaining,proto3" json:"remaining,omitempty"` // contains filtered or unexported fields }
func (*UpData) Descriptor
deprecated
func (*UpData) GetRemaining ¶
func (*UpData) ProtoMessage ¶
func (*UpData) ProtoMessage()
func (*UpData) ProtoReflect ¶
func (x *UpData) ProtoReflect() protoreflect.Message
type UpStart ¶
type UpStart struct { SourceId []byte `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"` DestinationId []byte `protobuf:"bytes,2,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"` Metadata *MD `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` Properties map[string][]byte `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpStart) Descriptor
deprecated
func (*UpStart) GetDestinationId ¶
func (*UpStart) GetMetadata ¶
func (*UpStart) GetProperties ¶
func (*UpStart) GetSourceId ¶
func (*UpStart) ProtoMessage ¶
func (*UpStart) ProtoMessage()
func (*UpStart) ProtoReflect ¶
func (x *UpStart) ProtoReflect() protoreflect.Message