v1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_blachris_arpcnet_v1_link_service_proto protoreflect.FileDescriptor
View Source 
var File_blachris_arpcnet_v1_rpcframe_proto protoreflect.FileDescriptor
View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Announce.ProtoReflect.Descriptor instead.

func (*Announce) GetDeadlineUnixMs 

func (x *Announce) GetDeadlineUnixMs() uint64

func (*Announce) GetId 

func (x *Announce) GetId() uint64

func (*Announce) GetName 

func (x *Announce) GetName() []byte

func (*Announce) GetValue 

func (x *Announce) GetValue() *Metric

func (*Announce) ProtoMessage 

func (*Announce) ProtoMessage()

func (*Announce) ProtoReflect 

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

func (*Announce) Reset 

func (x *Announce) Reset()

func (*Announce) String 

func (x *Announce) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use DownData.ProtoReflect.Descriptor instead.

func (*DownData) GetChunk 

func (x *DownData) GetChunk() []byte

func (*DownData) GetRemaining 

func (x *DownData) GetRemaining() uint32

func (*DownData) ProtoMessage 

func (*DownData) ProtoMessage()

func (*DownData) ProtoReflect 

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

func (*DownData) Reset 

func (x *DownData) Reset()

func (*DownData) String 

func (x *DownData) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use LinkFrame.ProtoReflect.Descriptor instead.

func (*LinkFrame) GetAnnounce 

func (x *LinkFrame) GetAnnounce() *Announce

func (*LinkFrame) GetQuery 

func (x *LinkFrame) GetQuery() *Query

func (*LinkFrame) GetRpcFrame 

func (x *LinkFrame) GetRpcFrame() *RPCFrame

func (*LinkFrame) GetType 

func (m *LinkFrame) GetType() isLinkFrame_Type

func (*LinkFrame) ProtoMessage 

func (*LinkFrame) ProtoMessage()

func (*LinkFrame) ProtoReflect 

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

func (*LinkFrame) Reset 

func (x *LinkFrame) Reset()

func (*LinkFrame) String 

func (x *LinkFrame) String() string

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_LinkClient interface {
	Send(*LinkFrame) error
	Recv() (*LinkFrame, error)
	grpc.ClientStream
}

type LinkService_LinkServer 

type LinkService_LinkServer interface {
	Send(*LinkFrame) error
	Recv() (*LinkFrame, error)
	grpc.ServerStream
}

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) Descriptor() ([]byte, []int)

Deprecated: Use MD.ProtoReflect.Descriptor instead.

func (*MD) GetKvPairs 

func (x *MD) GetKvPairs() []string

func (*MD) ProtoMessage 

func (*MD) ProtoMessage()

func (*MD) ProtoReflect 

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

func (*MD) Reset 

func (x *MD) Reset()

func (*MD) String 

func (x *MD) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetHops 

func (x *Metric) GetHops() int32

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

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

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetDeadlineUnixMs 

func (x *Query) GetDeadlineUnixMs() uint64

func (*Query) GetId 

func (x *Query) GetId() uint64

func (*Query) GetName 

func (x *Query) GetName() []byte

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RPCFrame.ProtoReflect.Descriptor instead.

func (*RPCFrame) GetDownData 

func (x *RPCFrame) GetDownData() *DownData

func (*RPCFrame) GetDownFinish 

func (x *RPCFrame) GetDownFinish() *DownFinish

func (*RPCFrame) GetDownResp 

func (x *RPCFrame) GetDownResp() *DownResponse

func (*RPCFrame) GetId 

func (x *RPCFrame) GetId() uint64

func (*RPCFrame) GetType 

func (m *RPCFrame) GetType() isRPCFrame_Type

func (*RPCFrame) GetUpCancel 

func (x *RPCFrame) GetUpCancel() *UpCancel

func (*RPCFrame) GetUpClose 

func (x *RPCFrame) GetUpClose() *UpClose

func (*RPCFrame) GetUpData 

func (x *RPCFrame) GetUpData() *UpData

func (*RPCFrame) GetUpStart 

func (x *RPCFrame) GetUpStart() *UpStart

func (*RPCFrame) ProtoMessage 

func (*RPCFrame) ProtoMessage()

func (*RPCFrame) ProtoReflect 

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

func (*RPCFrame) Reset 

func (x *RPCFrame) Reset()

func (*RPCFrame) String 

func (x *RPCFrame) String() string

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(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) Descriptor() ([]byte, []int)

Deprecated: Use UpCancel.ProtoReflect.Descriptor instead.

func (*UpCancel) GetMessage 

func (x *UpCancel) GetMessage() string

func (*UpCancel) ProtoMessage 

func (*UpCancel) ProtoMessage()

func (*UpCancel) ProtoReflect 

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

func (*UpCancel) Reset 

func (x *UpCancel) Reset()

func (*UpCancel) String 

func (x *UpCancel) String() string

type UpClose 

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

func (*UpClose) Descriptor deprecated 

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

Deprecated: Use UpClose.ProtoReflect.Descriptor instead.

func (*UpClose) ProtoMessage 

func (*UpClose) ProtoMessage()

func (*UpClose) ProtoReflect 

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

func (*UpClose) Reset 

func (x *UpClose) Reset()

func (*UpClose) String 

func (x *UpClose) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UpData.ProtoReflect.Descriptor instead.

func (*UpData) GetChunk 

func (x *UpData) GetChunk() []byte

func (*UpData) GetRemaining 

func (x *UpData) GetRemaining() uint32

func (*UpData) ProtoMessage 

func (*UpData) ProtoMessage()

func (*UpData) ProtoReflect 

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

func (*UpData) Reset 

func (x *UpData) Reset()

func (*UpData) String 

func (x *UpData) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use UpStart.ProtoReflect.Descriptor instead.

func (*UpStart) GetDestinationId 

func (x *UpStart) GetDestinationId() []byte

func (*UpStart) GetMetadata 

func (x *UpStart) GetMetadata() *MD

func (*UpStart) GetProperties 

func (x *UpStart) GetProperties() map[string][]byte

func (*UpStart) GetSourceId 

func (x *UpStart) GetSourceId() []byte

func (*UpStart) ProtoMessage 

func (*UpStart) ProtoMessage()

func (*UpStart) ProtoReflect 

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

func (*UpStart) Reset 

func (x *UpStart) Reset()

func (*UpStart) String 

func (x *UpStart) 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.