topics

type CreateOpts struct {
	Name             string `json:"id" required:"true"`
	Partition        int    `json:"partition,omitempty"`
	Replication      int    `json:"replication,omitempty"`
	SyncReplication  bool   `json:"sync_replication,omitempty"`
	RetentionTime    int    `json:"retention_time,omitempty"`
	SyncMessageFlush bool   `json:"sync_message_flush,omitempty"`
}

type CreateOptsBuilder interface {
	ToTopicCreateMap() (map[string]interface{}, error)
}

type CreateResult struct {
	golangsdk.Result
}

type DeleteOpts struct {
	Topics []string `json:"topics" required:"true"`
}

type DeleteOptsBuilder interface {
	ToTopicDeleteMap() (map[string]interface{}, error)
}

type DeleteResult struct {
	golangsdk.Result
}

type GetResult struct {
	golangsdk.Result
}

type Parameters struct {
	Name             string `json:"id"`
	Partition        int    `json:"partition"`
	Replication      int    `json:"replication"`
	SyncReplication  string `json:"sync_replication"`
	RetentionTime    int    `json:"retention_time"`
	SyncMessageFlush string `json:"sync_message_flush"`
}

type Topic struct {
	Size             int          `json:"size"`
	RemainPartitions int          `json:"remain_partitions"`
	MaxPartitions    int          `json:"max_partitions"`
	Topics           []Parameters `json:"topics"`
}

type TopicDelete struct {
	Name    string `json:"id"`
	Success bool   `json:"success"`
}

type TopicName struct {
	Name string `json:"id"`
}