nexus

Documentation

Index

• func CommandID(ctx context.Context) *int64
• func CtxWithCID(ctx context.Context, cmd *pb.Command) context.Context
• func New(transcriptCfg config.Workers, tgst tgstore.Store, met metrics.Metrics) (*nexus, error)
• type CommandIDKeyT
• type Connection
• type Nexus
• type Registry

Functions

func CommandID

func CommandID(ctx context.Context) *int64

func CtxWithCID

func CtxWithCID(ctx context.Context, cmd *pb.Command) context.Context

func New

func New(transcriptCfg config.Workers, tgst tgstore.Store, met metrics.Metrics) (*nexus, error)

Types

type CommandIDKeyT

type CommandIDKeyT int64

const CommandIDKey CommandIDKeyT = 0

type Connection

type Connection interface {
	io.Closer
	CloseCh()

	NetConn() net.Conn

	Shutdown()

	Send(broadcast.ToClientMsg) error
}

type Nexus

type Nexus interface {
	Broadcast(broadcast.Message)
	PrivateRoutes(chi.Router)
	Transcriber() workers.Manager
	Go(ctx context.Context)
	HUP(*config.Config)
}

type Registry

type Registry interface {
	NewClient(Connection, entities.Subject) *client
	Register(*client)
	Unregister(*client)
}