saf

Documentation

Index

• Constants
• Variables
• func Error(cond, msg string) error
• type Message
• type Stream
  • func (s *Stream) Ch() <-chan json.RawMessage
  • func (s *Stream) Close() error
  • func (s *Stream) Err() error
  • func (s *Stream) Run(ctx context.Context, r io.ReadCloser)

Constants

const (
	CondBegin     = "begin"
	CondOngoing   = "ongoing"
	CondSucceeded = "succeeded"
	CondLimited   = "limited"
	CondFailed    = "failed"
)

Variables

var (
	ErrStreamTruncated = errors.New("saf stream truncated")
	ErrStreamLimited   = fmt.Errorf("saf stream %s", CondLimited)
)

Functions

func Error

func Error(cond, msg string) error

Types

type Message

type Message struct {
	Cond string          `json:"cond,omitempty"`
	Msg  string          `json:"msg,omitempty"`
	Obj  json.RawMessage `json:"obj,omitempty"`
}

type Stream

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

func (*Stream) Ch

func (s *Stream) Ch() <-chan json.RawMessage

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) Err

func (s *Stream) Err() error

func (*Stream) Run

func (s *Stream) Run(ctx context.Context, r io.ReadCloser)