peer_api

Apr 22, 2024

Changes in this version

type GetPeerInfoRequest

+ func (x *GetPeerInfoRequest) MarshalProtoText() string

type GetPeerInfoResponse

+ func (x *GetPeerInfoResponse) MarshalProtoText() string

type IdentifyRequest

+ func (x *IdentifyRequest) MarshalProtoText() string

type IdentifyResponse

+ func (x *IdentifyResponse) MarshalProtoText() string

type PeerInfo

+ func (x *PeerInfo) MarshalProtoText() string

Apr 22, 2024

Changes in this version

type GetPeerInfoRequest

+ func (x *GetPeerInfoRequest) MarshalJSON() ([]byte, error)

+ func (x *GetPeerInfoRequest) MarshalProtoJSON(s *json.MarshalState)

+ func (x *GetPeerInfoRequest) UnmarshalJSON(b []byte) error

+ func (x *GetPeerInfoRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

type GetPeerInfoResponse

+ func (x *GetPeerInfoResponse) MarshalJSON() ([]byte, error)

+ func (x *GetPeerInfoResponse) MarshalProtoJSON(s *json.MarshalState)

+ func (x *GetPeerInfoResponse) UnmarshalJSON(b []byte) error

+ func (x *GetPeerInfoResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

type IdentifyRequest

+ func (x *IdentifyRequest) MarshalJSON() ([]byte, error)

+ func (x *IdentifyRequest) MarshalProtoJSON(s *json.MarshalState)

+ func (x *IdentifyRequest) UnmarshalJSON(b []byte) error

+ func (x *IdentifyRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

type IdentifyResponse

+ func (x *IdentifyResponse) MarshalJSON() ([]byte, error)

+ func (x *IdentifyResponse) MarshalProtoJSON(s *json.MarshalState)

+ func (x *IdentifyResponse) UnmarshalJSON(b []byte) error

+ func (x *IdentifyResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

type PeerInfo

+ func (x *PeerInfo) MarshalJSON() ([]byte, error)

+ func (x *PeerInfo) MarshalProtoJSON(s *json.MarshalState)

+ func (x *PeerInfo) UnmarshalJSON(b []byte) error

+ func (x *PeerInfo) UnmarshalProtoJSON(s *json.UnmarshalState)

May 20, 2023

Changes in this version

type GetPeerInfoRequest

+ func (m *GetPeerInfoRequest) CloneMessageVT() proto.Message

+ func (this *GetPeerInfoRequest) EqualMessageVT(thatMsg proto.Message) bool

type GetPeerInfoResponse

+ func (m *GetPeerInfoResponse) CloneMessageVT() proto.Message

+ func (this *GetPeerInfoResponse) EqualMessageVT(thatMsg proto.Message) bool

type IdentifyRequest

+ func (m *IdentifyRequest) CloneMessageVT() proto.Message

+ func (this *IdentifyRequest) EqualMessageVT(thatMsg proto.Message) bool

type IdentifyResponse

+ func (m *IdentifyResponse) CloneMessageVT() proto.Message

+ func (this *IdentifyResponse) EqualMessageVT(thatMsg proto.Message) bool

type PeerInfo

+ func (m *PeerInfo) CloneMessageVT() proto.Message

+ func (this *PeerInfo) EqualMessageVT(thatMsg proto.Message) bool

Jan 21, 2023

Changes in this version

type SRPCPeerService_IdentifyStream

+ SendAndClose func(*IdentifyResponse) error

Dec 2, 2022

Changes in this version

type GetPeerInfoRequest

+ func (m *GetPeerInfoRequest) CloneGenericVT() proto.Message

+ func (m *GetPeerInfoRequest) CloneVT() *GetPeerInfoRequest

type GetPeerInfoResponse

+ func (m *GetPeerInfoResponse) CloneGenericVT() proto.Message

+ func (m *GetPeerInfoResponse) CloneVT() *GetPeerInfoResponse

type IdentifyRequest

+ func (m *IdentifyRequest) CloneGenericVT() proto.Message

+ func (m *IdentifyRequest) CloneVT() *IdentifyRequest

type IdentifyResponse

+ func (m *IdentifyResponse) CloneGenericVT() proto.Message

+ func (m *IdentifyResponse) CloneVT() *IdentifyResponse

type PeerInfo

+ func (m *PeerInfo) CloneGenericVT() proto.Message

+ func (m *PeerInfo) CloneVT() *PeerInfo

Oct 12, 2022

Changes in this version

+ func NewSRPCPeerServiceHandler(impl SRPCPeerServiceServer, serviceID string) srpc.Handler

type SRPCPeerServiceClient

+ func NewSRPCPeerServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCPeerServiceClient

Jul 8, 2022

Changes in this version

+ const SRPCPeerServiceServiceID

+ func SRPCRegisterPeerService(mux srpc.Mux, impl SRPCPeerServiceServer) error

type GetPeerInfoRequest

+ func (this *GetPeerInfoRequest) EqualVT(that *GetPeerInfoRequest) bool

type GetPeerInfoResponse

+ func (this *GetPeerInfoResponse) EqualVT(that *GetPeerInfoResponse) bool

type IdentifyRequest

+ func (this *IdentifyRequest) EqualVT(that *IdentifyRequest) bool

type IdentifyResponse

+ func (this *IdentifyResponse) EqualVT(that *IdentifyResponse) bool

type PeerInfo

+ func (this *PeerInfo) EqualVT(that *PeerInfo) bool

+ type SRPCPeerServiceClient interface

+ GetPeerInfo func(ctx context.Context, in *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ Identify func(ctx context.Context, in *IdentifyRequest) (SRPCPeerService_IdentifyClient, error)

+ SRPCClient func() srpc.Client

+ func NewSRPCPeerServiceClient(cc srpc.Client) SRPCPeerServiceClient

+ type SRPCPeerServiceHandler struct

+ func (SRPCPeerServiceHandler) GetMethodIDs() []string

+ func (SRPCPeerServiceHandler) GetServiceID() string

+ func (SRPCPeerServiceHandler) InvokeMethod_GetPeerInfo(impl SRPCPeerServiceServer, strm srpc.Stream) error

+ func (SRPCPeerServiceHandler) InvokeMethod_Identify(impl SRPCPeerServiceServer, strm srpc.Stream) error

+ func (d *SRPCPeerServiceHandler) InvokeMethod(serviceID, methodID string, strm srpc.Stream) (bool, error)

+ type SRPCPeerServiceServer interface

+ GetPeerInfo func(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ Identify func(*IdentifyRequest, SRPCPeerService_IdentifyStream) error

+ type SRPCPeerServiceUnimplementedServer struct

+ func (s *SRPCPeerServiceUnimplementedServer) GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ func (s *SRPCPeerServiceUnimplementedServer) Identify(*IdentifyRequest, SRPCPeerService_IdentifyStream) error

+ type SRPCPeerService_GetPeerInfoStream interface

+ SendAndClose func(*GetPeerInfoResponse) error

+ type SRPCPeerService_IdentifyClient interface

+ Recv func() (*IdentifyResponse, error)

+ RecvTo func(*IdentifyResponse) error

+ type SRPCPeerService_IdentifyStream interface

+ Send func(*IdentifyResponse) error

Jun 3, 2022

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_github_com_aperturerobotics_bifrost_peer_api_api_proto protoreflect.FileDescriptor

type GetPeerInfoRequest

+ func (m *GetPeerInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetPeerInfoRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetPeerInfoRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *GetPeerInfoRequest) SizeVT() (n int)

+ func (m *GetPeerInfoRequest) UnmarshalVT(dAtA []byte) error

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

type GetPeerInfoResponse

+ func (m *GetPeerInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *GetPeerInfoResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *GetPeerInfoResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *GetPeerInfoResponse) SizeVT() (n int)

+ func (m *GetPeerInfoResponse) UnmarshalVT(dAtA []byte) error

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

type IdentifyRequest

+ func (m *IdentifyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IdentifyRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IdentifyRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *IdentifyRequest) SizeVT() (n int)

+ func (m *IdentifyRequest) UnmarshalVT(dAtA []byte) error

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

type IdentifyResponse

+ func (m *IdentifyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *IdentifyResponse) MarshalToVT(dAtA []byte) (int, error)

+ func (m *IdentifyResponse) MarshalVT() (dAtA []byte, err error)

+ func (m *IdentifyResponse) SizeVT() (n int)

+ func (m *IdentifyResponse) UnmarshalVT(dAtA []byte) error

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

type PeerInfo

+ func (m *PeerInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PeerInfo) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PeerInfo) MarshalVT() (dAtA []byte, err error)

+ func (m *PeerInfo) SizeVT() (n int)

+ func (m *PeerInfo) UnmarshalVT(dAtA []byte) error

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

Mar 21, 2022

Changes in this version

+ func DRPCRegisterPeerService(mux drpc.Mux, impl DRPCPeerServiceServer) error

+ type DRPCPeerServiceClient interface

+ DRPCConn func() drpc.Conn

+ GetPeerInfo func(ctx context.Context, in *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ Identify func(ctx context.Context, in *IdentifyRequest) (DRPCPeerService_IdentifyClient, error)

+ func NewDRPCPeerServiceClient(cc drpc.Conn) DRPCPeerServiceClient

+ type DRPCPeerServiceDescription struct

+ func (DRPCPeerServiceDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

+ func (DRPCPeerServiceDescription) NumMethods() int

+ type DRPCPeerServiceServer interface

+ GetPeerInfo func(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ Identify func(*IdentifyRequest, DRPCPeerService_IdentifyStream) error

+ type DRPCPeerServiceUnimplementedServer struct

+ func (s *DRPCPeerServiceUnimplementedServer) GetPeerInfo(context.Context, *GetPeerInfoRequest) (*GetPeerInfoResponse, error)

+ func (s *DRPCPeerServiceUnimplementedServer) Identify(*IdentifyRequest, DRPCPeerService_IdentifyStream) error

+ type DRPCPeerService_GetPeerInfoStream interface

+ SendAndClose func(*GetPeerInfoResponse) error

+ type DRPCPeerService_IdentifyClient interface

+ Recv func() (*IdentifyResponse, error)

+ type DRPCPeerService_IdentifyStream interface

+ Send func(*IdentifyResponse) error

+ type GetPeerInfoRequest struct

+ PeerId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPeerInfoRequest) ProtoMessage()

+ func (m *GetPeerInfoRequest) GetPeerId() string

+ func (m *GetPeerInfoRequest) Reset()

+ func (m *GetPeerInfoRequest) String() string

+ func (m *GetPeerInfoRequest) XXX_DiscardUnknown()

+ func (m *GetPeerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPeerInfoRequest) XXX_Merge(src proto.Message)

+ func (m *GetPeerInfoRequest) XXX_Size() int

+ func (m *GetPeerInfoRequest) XXX_Unmarshal(b []byte) error

+ type GetPeerInfoResponse struct

+ LocalPeers []*PeerInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPeerInfoResponse) ProtoMessage()

+ func (m *GetPeerInfoResponse) GetLocalPeers() []*PeerInfo

+ func (m *GetPeerInfoResponse) Reset()

+ func (m *GetPeerInfoResponse) String() string

+ func (m *GetPeerInfoResponse) XXX_DiscardUnknown()

+ func (m *GetPeerInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GetPeerInfoResponse) XXX_Merge(src proto.Message)

+ func (m *GetPeerInfoResponse) XXX_Size() int

+ func (m *GetPeerInfoResponse) XXX_Unmarshal(b []byte) error

+ type IdentifyRequest struct

+ Config *controller.Config

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IdentifyRequest) ProtoMessage()

+ func (m *IdentifyRequest) GetConfig() *controller.Config

+ func (m *IdentifyRequest) Reset()

+ func (m *IdentifyRequest) String() string

+ func (m *IdentifyRequest) XXX_DiscardUnknown()

+ func (m *IdentifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IdentifyRequest) XXX_Merge(src proto.Message)

+ func (m *IdentifyRequest) XXX_Size() int

+ func (m *IdentifyRequest) XXX_Unmarshal(b []byte) error

+ type IdentifyResponse struct

+ ControllerStatus exec.ControllerStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IdentifyResponse) ProtoMessage()

+ func (m *IdentifyResponse) GetControllerStatus() exec.ControllerStatus

+ func (m *IdentifyResponse) Reset()

+ func (m *IdentifyResponse) String() string

+ func (m *IdentifyResponse) XXX_DiscardUnknown()

+ func (m *IdentifyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IdentifyResponse) XXX_Merge(src proto.Message)

+ func (m *IdentifyResponse) XXX_Size() int

+ func (m *IdentifyResponse) XXX_Unmarshal(b []byte) error

+ type PeerInfo struct

+ PeerId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewPeerInfo(p peer.Peer) (*PeerInfo, error)

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

+ func (*PeerInfo) ProtoMessage()

+ func (m *PeerInfo) GetPeerId() string

+ func (m *PeerInfo) Reset()

+ func (m *PeerInfo) String() string

+ func (m *PeerInfo) XXX_DiscardUnknown()

+ func (m *PeerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PeerInfo) XXX_Merge(src proto.Message)

+ func (m *PeerInfo) XXX_Size() int

+ func (m *PeerInfo) XXX_Unmarshal(b []byte) error