rtm

package
v0.0.0-...-76c7a1d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 6, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Provider = wire.NewSet(

	New, wire.Bind(new(API), new(*Protocol)),
)

Provider is the configuration specific dependency to be injected to lower level plugins

Functions

This section is empty.

Types

type API

type API interface {
	OnAdd(connectionKey model.ConnectionKey, stubChannels map[string]*model_cp.StubChannel)
	OnDelete(connectionKey model.ConnectionKey) (*model.StreamData, error)
	OnData(conn pb.MsmControlPlane_SendServer, stream *pb.Message) (*model.StreamData, error)
}

API provides external access to

type Protocol

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

Protocol holds the rtm protocol specific data structures

func New

func New(cfg *config.Cfg) *Protocol

func (*Protocol) OnAdd

func (p *Protocol) OnAdd(connectionKey model.ConnectionKey, stubChannels map[string]*model_cp.StubChannel)

func (*Protocol) OnData

func (p *Protocol) OnData(conn pb.MsmControlPlane_SendServer, stream *pb.Message) (*model.StreamData, error)

func (*Protocol) OnDelete

func (p *Protocol) OnDelete(connectionKey model.ConnectionKey) (*model.StreamData, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL