io

type MessageClaim struct {
	SourceId      string `json:"source_id"`
	DestinationId string `json:"destination_id"`
}

type Publish struct {
	Message string `json:"message"`
}

type RequestDeletePartitionMessage struct {
	Subscriber  string
	PartitionId string
	MessageId   string
}

type ResponseMessage struct {
	Id      string `json:"id"`
	Message string `json:"message"`
}

type ResponseMessages []ResponseMessage

type Subscriber struct {
	Name   string        `json:"name"`
	Option SubscriberOpt `json:"option"`
}

type SubscriberMessage struct {
	Name               string `json:"name"`
	UnpublishedMessage int    `json:"unpublished_message"`
	UnackedMessage     int    `json:"unacked_message"`
}

type SubscriberMessages []SubscriberMessage

type SubscriberOpt struct {
	MaxAttempts        int    `json:"max_attempts"`
	VisibilityDuration string `json:"visibility_duration"`
}

type Subscribers []Subscriber

type Topic struct {
	Name        string      `json:"name"`
	Subscribers Subscribers `json:"subscribers"`
}