transaction

Documentation

Index

• type Streamer
  • func NewStreamer(handler getters.TransactionHandler, log *logan.Entry) *Streamer
  • func (s *Streamer) StreamTransactions(ctx context.Context, changeTypes, entryTypes []int) (<-chan regources.TransactionListResponse, <-chan error)

Types

type Streamer

type Streamer struct {
	getters.TransactionHandler
	// contains filtered or unexported fields
}

func NewStreamer

func NewStreamer(handler getters.TransactionHandler, log *logan.Entry) *Streamer

func (*Streamer) StreamTransactions

func (s *Streamer) StreamTransactions(ctx context.Context, changeTypes, entryTypes []int,
) (<-chan regources.TransactionListResponse, <-chan error)