bifrost_api

Documentation

Index

• Variables
• func RegisterAsSRPCServer(s BifrostAPIServer, mux srpc.Mux)
• type API
  • func NewAPI(bus bus.Bus, conf *Config) (*API, error)
  • func (a *API) AcceptStream(serv stream_api.SRPCStreamService_AcceptStreamStream) error
  • func (a *API) DialStream(serv stream_api.SRPCStreamService_DialStreamStream) error
  • func (a *API) ForwardStreams(req *stream_api.ForwardStreamsRequest, ...) error
  • func (a *API) GetPeerInfo(ctx context.Context, req *peer_api.GetPeerInfoRequest) (*peer_api.GetPeerInfoResponse, error)
  • func (a *API) Identify(req *peer_api.IdentifyRequest, serv peer_api.SRPCPeerService_IdentifyStream) error
  • func (a *API) ListenStreams(req *stream_api.ListenStreamsRequest, ...) error
  • func (a *API) RegisterAsSRPCServer(mux srpc.Mux)
  • func (a *API) Subscribe(serv pubsub_api.SRPCPubSubService_SubscribeStream) error
• type BifrostAPIClient
  • func NewBifrostAPIClient(cc srpc.Client) BifrostAPIClient
• type BifrostAPIServer
• type BusAPI
• type Config
  • func (m *Config) CloneMessageVT() proto.Message
  • func (m *Config) CloneVT() *Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (this *Config) EqualMessageVT(thatMsg proto.Message) bool
  • func (this *Config) EqualVT(that *Config) bool
  • func (x *Config) GetBusConfig() *api.Config
  • func (m *Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)
  • func (m *Config) MarshalToVT(dAtA []byte) (int, error)
  • func (m *Config) MarshalVT() (dAtA []byte, err error)
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (m *Config) SizeVT() (n int)
  • func (x *Config) String() string
  • func (m *Config) UnmarshalVT(dAtA []byte) error
• type SRPCBifrostAPIClient
• type SRPCBifrostAPIServer

Variables

var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)

var File_github_com_aperturerobotics_bifrost_daemon_api_api_proto protoreflect.FileDescriptor

Functions

func RegisterAsSRPCServer

func RegisterAsSRPCServer(s BifrostAPIServer, mux srpc.Mux)

RegisterAsSRPCServer registers a server with a SRPC mux.

Types

type API

type API struct {
	*BusAPI
	// contains filtered or unexported fields
}

API implements the daemon API.

func NewAPI

func NewAPI(bus bus.Bus, conf *Config) (*API, error)

NewAPI constructs a new instance of the API.

func (*API) AcceptStream

func (a *API) AcceptStream(serv stream_api.SRPCStreamService_AcceptStreamStream) error

AcceptStream accepts an incoming stream. Stream data is sent over the request / response streams.

func (*API) DialStream

func (a *API) DialStream(serv stream_api.SRPCStreamService_DialStreamStream) error

DialStream dials a outgoing stream. Stream data is sent over the request / response streams.

func (*API) ForwardStreams

func (a *API) ForwardStreams(
	req *stream_api.ForwardStreamsRequest,
	serv stream_api.SRPCStreamService_ForwardStreamsStream,
) error

ForwardStreams forwards streams to the target multiaddress. Handles HandleMountedStream directives by contacting the target.

func (*API) GetPeerInfo

func (a *API) GetPeerInfo(
	ctx context.Context,
	req *peer_api.GetPeerInfoRequest,
) (*peer_api.GetPeerInfoResponse, error)

GetPeerInfo returns the peer information

func (*API) Identify

func (a *API) Identify(
	req *peer_api.IdentifyRequest,
	serv peer_api.SRPCPeerService_IdentifyStream,
) error

Identify loads and manages a private key identity.

func (*API) ListenStreams

func (a *API) ListenStreams(
	req *stream_api.ListenStreamsRequest,
	serv stream_api.SRPCStreamService_ListenStreamsStream,
) error

ListenStreams listens for streams on the multiaddress.

func (*API) RegisterAsSRPCServer

func (a *API) RegisterAsSRPCServer(mux srpc.Mux)

RegisterAsSRPCServer registers the API to the SRPC mux.

func (*API) Subscribe

func (a *API) Subscribe(serv pubsub_api.SRPCPubSubService_SubscribeStream) error

Subscribe subscribes to a pubsub channel.

TODO: move this code to pubsub/api

type BifrostAPIClient

type BifrostAPIClient interface {
	bus_api.SRPCControllerBusServiceClient
	stream_api.SRPCStreamServiceClient
	peer_api.SRPCPeerServiceClient
	pubsub_api.SRPCPubSubServiceClient
}

BifrostAPIClient is the bifrost daemon client interface.

func NewBifrostAPIClient

func NewBifrostAPIClient(cc srpc.Client) BifrostAPIClient

NewBifrostAPIClient constructs a new bifrost api client.

type BifrostAPIServer

type BifrostAPIServer interface {
	bus_api.SRPCControllerBusServiceServer
	stream_api.SRPCStreamServiceServer
	peer_api.SRPCPeerServiceServer
	pubsub_api.SRPCPubSubServiceServer
}

BifrostAPIServer is the bifrost daemon server interface.

type BusAPI

type BusAPI = bus_api.API

BusAPI implements the controller bus api.

type Config

type Config struct {

	// BusConfig configures the bus api.
	BusConfig *api.Config `protobuf:"bytes,1,opt,name=bus_config,json=busConfig,proto3" json:"bus_config,omitempty"`
	// contains filtered or unexported fields
}

Config configures the API.

func (*Config) CloneMessageVT

func (m *Config) CloneMessageVT() proto.Message

func (*Config) CloneVT

func (m *Config) CloneVT() *Config

func (*Config) Descriptor

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) EqualMessageVT

func (this *Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Config) EqualVT

func (this *Config) EqualVT(that *Config) bool

func (*Config) GetBusConfig

func (x *Config) GetBusConfig() *api.Config

func (*Config) MarshalToSizedBufferVT

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

func (*Config) MarshalToVT

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

func (*Config) MarshalVT

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

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

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

func (*Config) Reset

func (x *Config) Reset()

func (*Config) SizeVT

func (m *Config) SizeVT() (n int)

func (*Config) String

func (x *Config) String() string

func (*Config) UnmarshalVT

func (m *Config) UnmarshalVT(dAtA []byte) error

type SRPCBifrostAPIClient

type SRPCBifrostAPIClient = BifrostAPIClient

SRPCBifrostAPIClient is the bifrost daemon client interface.

type SRPCBifrostAPIServer

type SRPCBifrostAPIServer = BifrostAPIServer

SRPCBifrostAPIServer is the bifrost daemon server interface.