signaling_echo

Apr 22, 2024

Changes in this version

type Config

+ func (x *Config) MarshalProtoText() string

Apr 22, 2024

Changes in this version

type Config

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

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

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

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

Jan 25, 2024

Changes in this version

+ const ConfigID

+ const ControllerID

+ 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_signaling_echo_echo_proto protoreflect.FileDescriptor

+ var Version = semver.MustParse("0.0.1")

+ func NewFactory(b bus.Bus) controller.Factory

+ type Config struct

+ SignalingId string

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

+ func (*Config) ProtoMessage()

+ func (c *Config) EqualsConfig(c2 config.Config) bool

+ func (c *Config) GetConfigID() string

+ func (c *Config) Validate() error

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

+ func (m *Config) CloneVT() *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 (m *Config) SizeVT() (n int)

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

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

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

+ func (x *Config) GetSignalingId() string

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

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type Controller struct

+ func (c *Controller) Close() error

+ func (c *Controller) HandleDirective(ctx context.Context, di directive.Instance) ([]directive.Resolver, error)

+ type EchoResolver struct

+ func NewEchoResolver(le *logrus.Entry, dir signaling.HandleSignalPeer) (*EchoResolver, error)

+ func (r *EchoResolver) Resolve(ctx context.Context, handler directive.ResolverHandler) error

+ type MountedStreamHandler struct

+ func NewMountedStreamHandler(le *logrus.Entry, bus bus.Bus) (*MountedStreamHandler, error)

+ func (m *MountedStreamHandler) HandleMountedStream(ctx context.Context, strm link.MountedStream) error