subscription

type ConsumerSetting struct {
	Name         string `json:"name"`
	Partitions   []int  `json:"partitions"`
	StartFromSeq uint64 `json:"startFromSeq"`
}

type CreateSubscriptionReply struct {
	core.ErrorReply
	SubscriptionID string               `json:"subscriptionID"`
	Setting        *SubscriptionSetting `json:"setting"`
}

type CreateSubscriptionRequest struct {
	Setting *SubscriptionSetting `json:"setting"`
}

type DeleteSubscriptionReply struct {
	core.ErrorReply
}

type DeleteSubscriptionRequest struct {
	SubscriptionID string `json:"subscriptionID"`
}

type GetSubscriptionReply struct {
	core.ErrorReply
	SubscriptionID string               `json:"subscriptionID"`
	Setting        *SubscriptionSetting `json:"setting"`
}

type GetSubscriptionRequest struct {
	SubscriptionID string `json:"subscriptionID"`
}

type ListSubscriptionsReply struct {
	core.ErrorReply

	Subscriptions []*SubscriptionSetting `json:"subscriptions"`
}

type ListSubscriptionsRequest struct {
	Product string `json:"product"`
}

type Options struct {
	Domain  string
	Verbose bool
}

type PrepareSubscriptionReply struct {
	core.ErrorReply
}

type PrepareSubscriptionRequest struct {
	SubscriptionID string `json:"subscriptionID"`
}

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

type SubscriptionSetting struct {
	Product   string             `json:"product"`
	Consumers []*ConsumerSetting `json:"consumers"`
	CreatedAt time.Time          `json:"createdAt"`
	UpdatedAt time.Time          `json:"updatedAt"`
}

type UpdateSubscriptionReply struct {
	core.ErrorReply
	Setting *SubscriptionSetting `json:"setting"`
}

type UpdateSubscriptionRequest struct {
	SubscriptionID string               `json:"subscriptionID"`
	Setting        *SubscriptionSetting `json:"setting"`
}