inprocess

Documentation

Overview

Package inprocess implements an in-process signaling backend using Go channels

Index

• func NewBackend(cfg *signaling.BackendConfig, logger *log.Logger) (signaling.Backend, error)
• type Backend
  • func (b *Backend) Close() error
  • func (b *Backend) Publish(_ context.Context, kp *crypto.KeyPair, msg *signaling.Message) error
  • func (b *Backend) Subscribe(_ context.Context, kp *crypto.KeyPair, h signaling.MessageHandler) (bool, error)
  • func (b *Backend) Type() signalingproto.BackendType
  • func (b *Backend) Unsubscribe(_ context.Context, kp *crypto.KeyPair, h signaling.MessageHandler) (bool, error)

Functions

func NewBackend

func NewBackend(cfg *signaling.BackendConfig, logger *log.Logger) (signaling.Backend, error)

Types

type Backend

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

func (*Backend) Close

func (b *Backend) Close() error

func (*Backend) Publish

func (b *Backend) Publish(_ context.Context, kp *crypto.KeyPair, msg *signaling.Message) error

func (*Backend) Subscribe

func (b *Backend) Subscribe(_ context.Context, kp *crypto.KeyPair, h signaling.MessageHandler) (bool, error)

func (*Backend) Type

func (b *Backend) Type() signalingproto.BackendType

func (*Backend) Unsubscribe

func (b *Backend) Unsubscribe(_ context.Context, kp *crypto.KeyPair, h signaling.MessageHandler) (bool, error)