stream

Documentation

Index

• type Msg
• type ReplayBundle
• type ResponseUnknownMsg
• type Status
• type Stream
  • func New(req *pbsubstreamsrpc.Request, client pbsubstreamsrpc.StreamClient, ...) *Stream
  • func (s *Stream) Init() tea.Cmd
  • func (s *Stream) StartStream() tea.Msg
  • func (s *Stream) StreamStatus() Status
  • func (s *Stream) TargetParallelProcessingBlock() uint64
  • func (s *Stream) Update(msg tea.Msg) tea.Cmd
• type StreamErrorMsg

Types

type Msg

type Msg int

const (
	ConnectingMsg Msg = iota
	ConnectedMsg
	BackprocessingMsg
	StreamingMsg
	InterruptStreamMsg
	EndOfStreamMsg
	ReplayedMsg
)

type ReplayBundle

type ReplayBundle []any

type ResponseUnknownMsg

type ResponseUnknownMsg string

type Status

type Status int

const (
	StatusRunning Status = 0
	StatusError   Status = 1
	StatusStopped Status = 2
)

type Stream

type Stream struct {
	ReplayBundle ReplayBundle
	// contains filtered or unexported fields
}

func New

func New(req *pbsubstreamsrpc.Request, client pbsubstreamsrpc.StreamClient, headers map[string]string, callOpts []grpc.CallOption) *Stream

func (*Stream) Init

func (s *Stream) Init() tea.Cmd

func (*Stream) StartStream

func (s *Stream) StartStream() tea.Msg

func (*Stream) StreamStatus

func (s *Stream) StreamStatus() Status

func (*Stream) TargetParallelProcessingBlock

func (s *Stream) TargetParallelProcessingBlock() uint64

func (*Stream) Update

func (s *Stream) Update(msg tea.Msg) tea.Cmd

type StreamErrorMsg

type StreamErrorMsg error