types

Documentation

Index

• Variables
• type AttachedStream
• type Read
  • func NewRead(cfg *ReadConfig) (*Read, error)
• type ReadConfig
• type Relay
  • func (r *Relay) StartRelay() error

Variables

var (
	ErrMissingReadOptions = errors.New("read options cannot be nil")
	ErrMissingPlumberID   = errors.New("plumber id cannot be empty")
)

Types

type AttachedStream

type AttachedStream struct {
	MessageCh chan *records.ReadRecord
}

type Read

type Read struct {
	AttachedClientsMutex *sync.RWMutex
	AttachedClients      map[string]*AttachedStream
	PlumberID            string
	ReadOptions          *opts.ReadOptions
	ContextCxl           context.Context
	CancelFunc           context.CancelFunc
	Backend              backends.Backend
	MessageDescriptors   map[pb.MDType]*desc.MessageDescriptor
	Log                  *logrus.Entry
}

func NewRead

func NewRead(cfg *ReadConfig) (*Read, error)

type ReadConfig

type ReadConfig struct {
	ReadOptions *opts.ReadOptions
	PlumberID   string
	Backend     backends.Backend
}

type Relay

type Relay struct {
	Active     bool               `json:"-"`
	Id         string             `json:"-"`
	CancelCtx  context.Context    `json:"-"`
	CancelFunc context.CancelFunc `json:"-"`
	RelayCh    chan interface{}   `json:"-"`
	Backend    backends.Backend   `json:"-"`
	Options    *opts.RelayOptions `json:"config"`
	// contains filtered or unexported fields
}

func (*Relay) StartRelay

func (r *Relay) StartRelay() error

StartRelay starts a configured relay, it's workers, and the GRPC workers