topics

Documentation

Index

• type CreateOpts
  • func (opts CreateOpts) ToTopicCreateMap() (map[string]interface{}, error)
• type CreateOptsBuilder
• type CreateResult
  • func Create(client *golangsdk.ServiceClient, opts CreateOptsBuilder, instanceId string) (r CreateResult)
  • func (r CreateResult) Extract() (*TopicName, error)
• type DeleteOpts
  • func (opts DeleteOpts) ToTopicDeleteMap() (map[string]interface{}, error)
• type DeleteOptsBuilder
• type DeleteResult
  • func Delete(client *golangsdk.ServiceClient, opts DeleteOptsBuilder, instanceId string) (r DeleteResult)
  • func (r DeleteResult) Extract() ([]TopicDelete, error)
• type GetResult
  • func Get(client *golangsdk.ServiceClient, instanceId string) (r GetResult)
  • func (r GetResult) Extract() (*Topic, error)
• type Parameters
• type Topic
• type TopicDelete
• type TopicName

Types

type CreateOpts

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"`
}

func (CreateOpts) ToTopicCreateMap

func (opts CreateOpts) ToTopicCreateMap() (map[string]interface{}, error)

type CreateOptsBuilder

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

type CreateResult

type CreateResult struct {
	golangsdk.Result
}

func Create

func Create(client *golangsdk.ServiceClient, opts CreateOptsBuilder, instanceId string) (r CreateResult)

func (CreateResult) Extract

func (r CreateResult) Extract() (*TopicName, error)

type DeleteOpts

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

func (DeleteOpts) ToTopicDeleteMap

func (opts DeleteOpts) ToTopicDeleteMap() (map[string]interface{}, error)

type DeleteOptsBuilder

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

type DeleteResult

type DeleteResult struct {
	golangsdk.Result
}

func Delete

func Delete(client *golangsdk.ServiceClient, opts DeleteOptsBuilder, instanceId string) (r DeleteResult)

func (DeleteResult) Extract

func (r DeleteResult) Extract() ([]TopicDelete, error)

type GetResult

type GetResult struct {
	golangsdk.Result
}

func Get

func Get(client *golangsdk.ServiceClient, instanceId string) (r GetResult)

func (GetResult) Extract

func (r GetResult) Extract() (*Topic, error)

type Parameters

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

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

type TopicDelete

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

type TopicName

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