websocks

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

type AckCommand struct {
	Acktype string `json:"acktype"`
	Channel string `json:"channel"`
	Error   string `json:"error,omitempty"`
	Ref     string `json:"ref"`
}

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

type AuthCommand struct {
	*InboundCommand
	Stream int32  `json:"stream"`
	Key    string `json:"key"`
	Secret string `json:"secret"`
}

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

type ConnectionInfo struct {
	Ref          string `json:"ref"`
	ConnectionID string `json:"connectionID"`
}

type InboundCommand struct {
	Command string `json:"cmd"`
	Ref     string `json:"ref"`
}

type NatsPublisher struct{}

type PublishCommand struct {
	*SubscribeCommand
	Data        string            `json:"data"`
	Source      string            `json:"source"`
	Type        string            `json:"type"`
	TypeVersion string            `json:"typeVersion"`
	ContentType string            `json:"contentType"`
	Metadata    map[string]string `json:"metadata"`
}

type PublishEventCommand struct {
	*SubscribeCommand
	Event *event.Event `json:"event"`
}

type Publisher interface {
	Publish(channel string, event *event.Event) error
}

type ReplayCommand struct {
	*SubscribeCommand
	Stream int32       `json:"stream"`
	JustMe bool        `json:"justme"`
	Dest   string      `json:"dest"`
	Query  ReplayRange `json:"query"`
}

type ReplayRange struct {
	StartTime *time.Time `json:"startTime"`
	EndTime   *time.Time `json:"endTime"`
	EndID     string     `json:"endID"`
}

type SubscribeCommand struct {
	*InboundCommand
	Subject string `json:"subject"`
}

type UnsubscribeCommand struct {
	*InboundCommand
	Subject string `json:"subject"`
}