Versions in this module Expand all Collapse all v1 v1.0.0 Oct 15, 2020 Changes in this version + var ContextAPIKey = contextKey("apikey") + var ContextAccessToken = contextKey("accesstoken") + var ContextBasicAuth = contextKey("basic") + var ContextOAuth2 = contextKey("token") + func CacheExpires(r *http.Response) time.Time + type APIClient struct + DefaultApi *DefaultApiService + func NewAPIClient(cfg *Configuration) *APIClient + func (c *APIClient) ChangeBasePath(path string) + func (c *APIClient) GetConfig() *Configuration + type APIKey struct + Key string + Prefix string + type APIResponse struct + Message string + Method string + Operation string + Payload []byte + RequestURL string + func NewAPIResponse(r *http.Response) *APIResponse + func NewAPIResponseWithError(errorMessage string) *APIResponse + type BasicAuth struct + Password string + UserName string + type ConfigCreate struct + Name string + Value string + type ConfigUpdate struct + Name string + ResetToDefault bool + Value string + type Configuration struct + BasePath string + Debug bool + DefaultHeader map[string]string + HTTPClient *http.Client + Host string + Scheme string + Servers []ServerConfiguration + UserAgent string + func NewConfiguration() *Configuration + func (c *Configuration) AddDefaultHeader(key string, value string) + func (c *Configuration) ServerUrl(index int, variables map[string]string) (string, error) + type DefaultApiService service + func (a *DefaultApiService) CreateTopic(ctx _context.Context, topicCreate TopicCreateRequest) (map[string]interface{}, *_nethttp.Response, error) + func (a *DefaultApiService) DeleteTopic(ctx _context.Context, topicName string) (map[string]interface{}, *_nethttp.Response, error) + func (a *DefaultApiService) GetTopic(ctx _context.Context, topicName string) (TopicDetail, *_nethttp.Response, error) + func (a *DefaultApiService) ListTopics(ctx _context.Context, localVarOptionals *ListTopicsOpts) ([]TopicDetail, *_nethttp.Response, error) + func (a *DefaultApiService) UpdateTopic(ctx _context.Context, topicName string, topicUpdate TopicUpdateRequest) (map[string]interface{}, *_nethttp.Response, error) + type GenericOpenAPIError struct + func (e GenericOpenAPIError) Body() []byte + func (e GenericOpenAPIError) Error() string + func (e GenericOpenAPIError) Model() interface{} + type ListTopicsOpts struct + Page optional.Int32 + PerPage optional.Int32 + TopicFilter optional.String + type ModelError struct + ErrorCode int32 + IncidentId string + Message string + type ReplicaAssignment struct + Brokers ReplicaAssignmentBrokers + Id int32 + type ReplicaAssignmentBrokers struct + Replicas []int32 + type ServerConfiguration struct + Description string + Url string + Variables map[string]ServerVariable + type ServerVariable struct + DefaultValue string + Description string + EnumValues []string + type TopicConfigs struct + CleanupPolicy string + MinInsyncReplicas string + RetentionBytes string + RetentionMs string + SegmentBytes string + SegmentIndexBytes string + SegmentMs string + type TopicCreateRequest struct + Configs []ConfigCreate + Name string + PartitionCount int64 + Partitions int64 + type TopicDetail struct + CleanupPolicy string + Configs TopicConfigs + Name string + Partitions int32 + ReplicaAssignments []ReplicaAssignment + ReplicationFactor int32 + RetentionMs int32 + type TopicUpdateRequest struct + Configs []ConfigUpdate + NewTotalPartitionCount int32
Go to main page