jsonstream

Documentation

Index

• Variables
• type Config
• type Translator
  • func NewTranslator(cfg Config) (*Translator, error)
  • func (t *Translator) TranslateLine(line []byte) ([]protocol.Event, error)
  • func (t *Translator) TranslateReader(ctx context.Context, r io.Reader) ([]protocol.Event, error)

Variables

var (
	ErrInvalidConfig      = errors.New("invalid jsonstream translator config")
	ErrInvalidStreamEvent = errors.New("invalid jsonstream event")
)

Types

type Config

type Config struct {
	SessionID string
	Provider  string
	Now       func() time.Time
}

type Translator

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

func NewTranslator

func NewTranslator(cfg Config) (*Translator, error)

func (*Translator) TranslateLine

func (t *Translator) TranslateLine(line []byte) ([]protocol.Event, error)

func (*Translator) TranslateReader

func (t *Translator) TranslateReader(ctx context.Context, r io.Reader) ([]protocol.Event, error)