apis

type APIRestJetStreamDataplaneHandler struct {
	goutils.RestAPIHandler
	// contains filtered or unexported fields
}

type APIRestJetStreamManagementHandler struct {
	goutils.RestAPIHandler
	// contains filtered or unexported fields
}

type APIRestReqStreamSubjects struct {
	// Subjects the list of new subject this stream will listen to
	Subjects []string `json:"subjects" validate:"required,min=1"`
}

type APIRestRespAllJetStreamConsumers struct {
	goutils.RestAPIBaseResponse
	// Consumers the set of consumer details mapped against consumer name
	Consumers map[string]APIRestRespConsumerInfo `json:"consumers,omitempty"`
}

type APIRestRespAllJetStreams struct {
	goutils.RestAPIBaseResponse
	// Streams the set of stream details mapped against its names
	Streams map[string]APIRestRespStreamInfo `json:"streams,omitempty"`
}

type APIRestRespConsumerConfig struct {
	// Description an optional description of the consumer
	Description string `json:"notes,omitempty"`
	// DeliverSubject subject this consumer is listening on
	DeliverSubject string `json:"deliver_subject,omitempty"`
	// DeliverGroup is the delivery group if this consumer uses delivery group
	//
	// A consumer using delivery group allows multiple clients to subscribe under the same consumer
	// and group name tuple. For subjects this consumer listens to, the messages will be shared
	// amongst the connected clients.
	DeliverGroup string `json:"deliver_group,omitempty"`
	// MaxDeliver max number of times a message can be deliveried (including retry) to this consumer
	MaxDeliver int `json:"max_deliver,omitempty"`
	// AckWait duration (ns) to wait for an ACK for the delivery of a message
	AckWait time.Duration `json:"ack_wait" swaggertype:"primitive,integer" validate:"required"`
	// FilterSubject sets the consumer to filter for subjects matching this NATs subject string
	//
	// See https://docs.nats.io/nats-concepts/subjects
	FilterSubject string `json:"filter_subject,omitempty"`
	// MaxWaiting NATS JetStream does not clearly document this
	MaxWaiting int `json:"max_waiting,omitempty"`
	// MaxAckPending controls the max number of un-ACKed messages permitted in-flight
	MaxAckPending int `json:"max_ack_pending,omitempty"`
}

type APIRestRespConsumerInfo struct {
	// Stream is the name of the stream
	Stream string `json:"stream_name" validate:"required"`
	// Name is the name of the consumer
	Name string `json:"name" validate:"required"`
	// Created is when this consumer was defined
	Created time.Time `json:"created" validate:"required"`
	// Config are the consumer config parameters
	Config APIRestRespConsumerConfig `json:"config" validate:"required"`
	// Delivered is the sequence number of the last message delivered
	Delivered APIRestRespSequenceInfo `json:"delivered" validate:"required"`
	// AckFloor is the sequence number of the last received ACKed
	//
	// For messages which failed to be ACKed (retry limit reached), the floor moves up to
	// include these message sequence numbers indicating these messages will not be retried.
	AckFloor APIRestRespSequenceInfo `json:"ack_floor" validate:"required"`
	// NumAckPending is the number of ACK pending / messages in-flight
	NumAckPending int `json:"num_ack_pending" validate:"required"`
	// NumRedelivered is the number of messages redelivered
	NumRedelivered int `json:"num_redelivered" validate:"required"`
	// NumWaiting NATS JetStream does not clearly document this
	NumWaiting int `json:"num_waiting" validate:"required"`
	// NumPending is the number of message to be delivered for this consumer
	NumPending uint64 `json:"num_pending" validate:"required"`
}

type APIRestRespDataMessage struct {
	goutils.RestAPIBaseResponse
	dataplane.MsgToDeliver
}

type APIRestRespOneJetStream struct {
	goutils.RestAPIBaseResponse
	// Stream the details for this stream
	Stream APIRestRespStreamInfo `json:"stream,omitempty"`
}

type APIRestRespOneJetStreamConsumer struct {
	goutils.RestAPIBaseResponse
	// Consumer the details regarding this consumer
	Consumer APIRestRespConsumerInfo `json:"consumer,omitempty"`
}

type APIRestRespSequenceInfo struct {
	// Consumer is consumer level sequence number
	Consumer uint64 `json:"consumer_seq" validate:"required"`
	// Stream is stream level sequence number
	Stream uint64 `json:"stream_seq" validate:"required"`
	// Last timestamp when these values updated
	Last *time.Time `json:"last_active,omitempty"`
}

type APIRestRespStreamConfig struct {
	// Name is the stream name
	Name string `json:"name" validate:"required"`
	// Description is an optional description of the stream
	Description string `json:"description,omitempty"`
	// Subjects is the list subjects this stream is listening on
	Subjects []string `json:"subjects,omitempty"`
	// MaxConsumers is the max number of consumers allowed on the stream
	MaxConsumers int `json:"max_consumers" validate:"required"`
	// MaxMsgs is the max number of messages the stream will store.
	//
	// Oldest messages are removed once limit breached.
	MaxMsgs int64 `json:"max_msgs" validate:"required"`
	// MaxBytes is the max number of message bytes the stream will store.
	//
	// Oldest messages are removed once limit breached.
	MaxBytes int64 `json:"max_bytes" validate:"required"`
	// MaxBytes is the max duration (ns) the stream will store a message
	//
	// Messages breaching the limit will be removed.
	MaxAge time.Duration `json:"max_age" swaggertype:"primitive,integer" validate:"required"`
	// MaxMsgsPerSubject is the maximum number of subjects allowed on this stream
	MaxMsgsPerSubject int64 `json:"max_msgs_per_subject" validate:"required"`
	// MaxMsgSize is the max size of a message allowed in this stream
	MaxMsgSize int32 `json:"max_msg_size,omitempty"`
}

type APIRestRespStreamInfo struct {
	// Config is the stream config parameters
	Config APIRestRespStreamConfig `json:"config" validate:"required"`
	// Created is the stream creation timestamp
	Created time.Time `json:"created" validate:"required"`
	// State is the stream current state
	State APIRestRespStreamState `json:"state" validate:"required"`
}

type APIRestRespStreamState struct {
	// Msgs is the number of messages in the stream
	Msgs uint64 `json:"messages" validate:"required"`
	// Bytes is the number of message bytes in the stream
	Bytes uint64 `json:"bytes" validate:"required"`
	// FirstSeq is the oldest message sequence number on the stream
	FirstSeq uint64 `json:"first_seq" validate:"required"`
	// FirstTime is the oldest message timestamp on the stream
	FirstTime time.Time `json:"first_ts" validate:"required"`
	// LastSeq is the newest message sequence number on the stream
	LastSeq uint64 `json:"last_seq" validate:"required"`
	// LastTime is the newest message timestamp on the stream
	LastTime time.Time `json:"last_ts" validate:"required"`
	// Consumers number of consumers on the stream
	Consumers int `json:"consumer_count" validate:"required"`
}

type MethodHandlers map[string]http.HandlerFunc