sonic

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

type ClientAck struct{}

type ClientAuth struct {
	Key  string
	User string
}

type ClientCancel struct{}

type ClientOption func(*Client) *Client

type Message interface {
	// contains filtered or unexported methods
}

type MessageRequest interface {
	Message
	// contains filtered or unexported methods
}

type MessageResponse interface {
	Message
	// contains filtered or unexported methods
}

type Query struct {
	AuthToken string
	Query     string
	Config    map[string]interface{}
}

type Stream interface {
	Receive(context.Context) (Message, error)
}

type StreamCompleted struct {
	Err error
}

type StreamOutput []interface{}

type StreamProgress struct {
	Status   StreamStatus
	Progress float64
	Total    float64
	Units    string
}

type StreamSchema []TypeHint

type StreamStarted struct{}

type StreamStatus int

type TypeHint struct {
	Name string
	Type interface{}
}