ccloud

package module
v0.0.0-...-9b0d275 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 13, 2025 License: Apache-2.0 Imports: 30 Imported by: 22

README

ccloud-sdk-go-v1-public

Public Golang SDK for Confluent Cloud

brew install protobuf
make protoc-binaries
go mod vendor
./compile

Copy the relevant generated files from their directories into the root of this project and open a PR.

Documentation

Index

Constants

View Source 
const (
	// ACCOUNTS base endpoint for accounts operations
	ACCOUNTS = "/api/accounts"
	// ACCOUNT specific user operation endpoint
	ACCOUNT = ACCOUNTS + "/%s"
)
View Source 
const (
	// USERS base endpoint for user operations
	USERS = "/api/users"
	// USER specific user operation endpoint
	USER            = USERS + "/%s"
	SERVICEACCOUNTS = "/api/service_accounts"
	SERVICEACCOUNT  = SERVICEACCOUNTS + "/%d"
	// deprecated: legacy endpoint for email invite to join org. org id in path is ignored, only the org id in the auth context matters
	INVITEURL = "/api/organizations/0/invites"
	// new invitation flow
	INVITATIONURL = "/api/invitations"
	// USER_PROFILES base endpoint for use profile operations
	USER_PROFILES = "/api/user_profiles"
	// customer-initiated org deletion flow
	SUSPEND_ORG_URL_TEMPLATE = "/api/organizations/%d/suspend"
)
View Source 
const SDKVersion = "v0.1.0"

Variables

View Source 
var (
	ErrInvalidLengthBilling = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBilling   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (

	// BaseClient represents a raw golang http client with the SDK http defaults.
	BaseClient = &http.Client{
		Timeout:   timeout,
		Transport: baseTransport,
	}

	// Requests should be serialized as JSONPB by default, specify something else if you want otherwise
	Request = NewJSONPBBodyProvider
)
View Source 
var (
	ErrInvalidLengthCore = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCore   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthError = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowError   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthFlow = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFlow   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthGrowth = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGrowth   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthOrg = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOrg   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthScheduler = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowScheduler   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthStreamgovernance = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStreamgovernance   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AuthType_name = map[int32]string{
	0: "AUTH_TYPE_UNKNOWN",
	1: "AUTH_TYPE_LOCAL",
	2: "AUTH_TYPE_SSO",
}
View Source 
var AuthType_value = map[string]int32{
	"AUTH_TYPE_UNKNOWN": 0,
	"AUTH_TYPE_LOCAL":   1,
	"AUTH_TYPE_SSO":     2,
}
View Source 
var BillingInterval_name = map[int32]string{
	0: "MONTHLY",
	1: "ANNUALLY",
}
View Source 
var BillingInterval_value = map[string]int32{
	"MONTHLY":  0,
	"ANNUALLY": 1,
}
View Source 
var BillingMethod_name = map[int32]string{
	0: "STRIPE",
	1: "MANUAL",
	2: "GCP",
	3: "SKIP",
	4: "MARKETPLACE",
	5: "NONE",
}
View Source 
var BillingMethod_value = map[string]int32{
	"STRIPE":      0,
	"MANUAL":      1,
	"GCP":         2,
	"SKIP":        3,
	"MARKETPLACE": 4,
	"NONE":        5,
}
View Source 
var ClusterStatus_name = map[int32]string{
	0: "PROVISIONING",
	1: "UP",
	2: "DOWN",
	3: "DELETING",
	4: "DELETED",
	5: "EXPANSION_PENDING",
	6: "EXPANDING",
	7: "SHRINK_PENDING",
	8: "SHRINKING",
	9: "STORAGE_EXPANDING",
}
View Source 
var ClusterStatus_value = map[string]int32{
	"PROVISIONING":      0,
	"UP":                1,
	"DOWN":              2,
	"DELETING":          3,
	"DELETED":           4,
	"EXPANSION_PENDING": 5,
	"EXPANDING":         6,
	"SHRINK_PENDING":    7,
	"SHRINKING":         8,
	"STORAGE_EXPANDING": 9,
}
View Source 
var ErrFailedToCreateExternalIdentity = fmt.Errorf("failed to create external identity")
View Source 
var ErrNotFound = &Error{Code: http.StatusNotFound, Message: "resource not found"}
View Source 
var GlobalSchemaRegistryLocation_name = map[int32]string{
	0: "NONE",
	1: "US",
	2: "EU",
	3: "APAC",
}
View Source 
var GlobalSchemaRegistryLocation_value = map[string]int32{
	"NONE": 0,
	"US":   1,
	"EU":   2,
	"APAC": 3,
}
View Source 
var MarketplaceCustomerState_name = map[int32]string{
	0: "CUSTOMER_APPROVAL_PENDING",
	1: "CUSTOMER_APPROVAL_SENT",
	2: "CUSTOMER_APPROVED",
	3: "CUSTOMER_DELETED",
}
View Source 
var MarketplaceCustomerState_value = map[string]int32{
	"CUSTOMER_APPROVAL_PENDING": 0,
	"CUSTOMER_APPROVAL_SENT":    1,
	"CUSTOMER_APPROVED":         2,
	"CUSTOMER_DELETED":          3,
}
View Source 
var MarketplacePartner_name = map[int32]string{
	0: "UNKNOWN",
	1: "GCP",
	2: "AWS",
	3: "AZURE",
}
View Source 
var MarketplacePartner_value = map[string]int32{
	"UNKNOWN": 0,
	"GCP":     1,
	"AWS":     2,
	"AZURE":   3,
}
View Source 
var MarketplaceSubscription_name = map[int32]string{
	0: "SUBSCRIPTION_NONE",
	1: "SUBSCRIPTION_PENDING",
	2: "SUBSCRIPTION_ACTIVE",
}
View Source 
var MarketplaceSubscription_value = map[string]int32{
	"SUBSCRIPTION_NONE":    0,
	"SUBSCRIPTION_PENDING": 1,
	"SUBSCRIPTION_ACTIVE":  2,
}
View Source 
var NetworkType_name = map[int32]string{
	0: "UNKNOWN_TYPE",
	1: "PUBLIC",
	2: "PRIVATE_LINK",
	3: "TRANSIT_GATEWAY",
	4: "VPC_PEERING",
	5: "INTERNAL",
}
View Source 
var NetworkType_value = map[string]int32{
	"UNKNOWN_TYPE":    0,
	"PUBLIC":          1,
	"PRIVATE_LINK":    2,
	"TRANSIT_GATEWAY": 3,
	"VPC_PEERING":     4,
	"INTERNAL":        5,
}
View Source 
var ProductLevel_name = map[int32]string{
	0: "DEVELOPER",
	1: "TEAM",
	2: "ENTERPRISE",
	3: "UNIFIED",
}
View Source 
var ProductLevel_value = map[string]int32{
	"DEVELOPER":  0,
	"TEAM":       1,
	"ENTERPRISE": 2,
	"UNIFIED":    3,
}
View Source 
var Sku_name = map[int32]string{
	0: "UNKNOWN",
	1: "BASIC_LEGACY",
	2: "BASIC",
	3: "STANDARD",
	4: "DEDICATED",
	5: "DEDICATED_LEGACY",
	6: "ENTERPRISE",
}
View Source 
var Sku_value = map[string]int32{
	"UNKNOWN":          0,
	"BASIC_LEGACY":     1,
	"BASIC":            2,
	"STANDARD":         3,
	"DEDICATED":        4,
	"DEDICATED_LEGACY": 5,
	"ENTERPRISE":       6,
}
View Source 
var SsoMode_name = map[int32]string{
	0: "SSO_MODE_UNKNOWN",
	1: "SSO_MODE_RESTRICTED",
	2: "SSO_MODE_LAX",
}
View Source 
var SsoMode_value = map[string]int32{
	"SSO_MODE_UNKNOWN":    0,
	"SSO_MODE_RESTRICTED": 1,
	"SSO_MODE_LAX":        2,
}
View Source 
var SuspensionEventType_name = map[int32]string{
	0: "SUSPENSION_EVENT_UNKNOWN",
	1: "SUSPENSION_EVENT_END_OF_FREE_TRIAL",
	2: "SUSPENSION_EVENT_CUSTOMER_INITIATED_ORG_DEACTIVATION",
	3: "SUSPENSION_EVENT_MARKETPLACE_ENTITLEMENT_CANCELLATION",
	4: "SUSPENSION_EVENT_NO_PAYMENT",
	5: "SUSPENSION_EVENT_SECURITY_INCIDENT_OR_ABUSE",
	6: "SUSPENSION_EVENT_OTHERS",
	7: "SUSPENSION_EVENT_INTERNAL_INITIATED_ORG_DEACTIVATION",
}
View Source 
var SuspensionEventType_value = map[string]int32{
	"SUSPENSION_EVENT_UNKNOWN":                              0,
	"SUSPENSION_EVENT_END_OF_FREE_TRIAL":                    1,
	"SUSPENSION_EVENT_CUSTOMER_INITIATED_ORG_DEACTIVATION":  2,
	"SUSPENSION_EVENT_MARKETPLACE_ENTITLEMENT_CANCELLATION": 3,
	"SUSPENSION_EVENT_NO_PAYMENT":                           4,
	"SUSPENSION_EVENT_SECURITY_INCIDENT_OR_ABUSE":           5,
	"SUSPENSION_EVENT_OTHERS":                               6,
	"SUSPENSION_EVENT_INTERNAL_INITIATED_ORG_DEACTIVATION":  7,
}
View Source 
var SuspensionStatusType_name = map[int32]string{
	0: "SUSPENSION_UNKNOWN",
	1: "SUSPENSION_IN_PROGRESS",
	2: "SUSPENSION_COMPLETED",
	3: "UNSUSPENSION_IN_PROGRESS",
	4: "SUSPENSION_FAILED",
	5: "UNSUSPENSION_FAILED",
}
View Source 
var SuspensionStatusType_value = map[string]int32{
	"SUSPENSION_UNKNOWN":       0,
	"SUSPENSION_IN_PROGRESS":   1,
	"SUSPENSION_COMPLETED":     2,
	"UNSUSPENSION_IN_PROGRESS": 3,
	"SUSPENSION_FAILED":        4,
	"UNSUSPENSION_FAILED":      5,
}

Functions

func E 

func E(args ...interface{}) error

E is a useful func for instantiating corev1.Errors.

func GetSlingWithNewClient 

func GetSlingWithNewClient(s *sling.Sling, client *http.Client, logger Logger) *sling.Sling

func InjectOAuth 

func InjectOAuth(ctx context.Context, accessToken string, baseClient *http.Client) *http.Client

func IsUnknownAPIKeyError 

func IsUnknownAPIKeyError(err error) bool

func Marshal 

func Marshal(v proto.Message) ([]byte, error)

func MarshalJSON 

func MarshalJSON(out io.Writer, v proto.Message) error

func MarshalJSONToBytes 

func MarshalJSONToBytes(v proto.Message) ([]byte, error)

func ReplyErr 

func ReplyErr(resp Errorer, err error) error

ReplyErr wraps reply and its error and returns the error if they are non-nil.

func Unmarshal 

func Unmarshal(b []byte, v proto.Message) error

func UnmarshalJSON 

func UnmarshalJSON(in io.Reader, v proto.Message) error

func UnmarshalJSONBytes 

func UnmarshalJSONBytes(b []byte, v proto.Message) error

func UnwrapQuotes 

func UnwrapQuotes(in string) (out string)

func WrapCoreErr 

func WrapCoreErr(err error, msg string) error

WrapCoreErr returns a corev1.Error for the given error and msg.

func WrapErr 

func WrapErr(err error, msg string) error

WrapErr returns a standard typed error if one exists, or a generic wrapped corev1.Error with the msg

func WrapQuotes 

func WrapQuotes(str string) string

Types

type APICredentials 

type APICredentials struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" db:"key,omitempty" url:"key,omitempty"`
	Secret               string   `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty" redact:"-" db:"secret,omitempty" url:"secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*APICredentials) Descriptor 

func (*APICredentials) Descriptor() ([]byte, []int)

func (*APICredentials) GetKey 

func (m *APICredentials) GetKey() string

func (*APICredentials) GetSecret 

func (m *APICredentials) GetSecret() string

func (*APICredentials) Marshal 

func (m *APICredentials) Marshal() (dAtA []byte, err error)

func (*APICredentials) MarshalTo 

func (m *APICredentials) MarshalTo(dAtA []byte) (int, error)

func (*APICredentials) ProtoMessage 

func (*APICredentials) ProtoMessage()

func (*APICredentials) Reset 

func (m *APICredentials) Reset()

func (*APICredentials) Size 

func (m *APICredentials) Size() (n int)

func (*APICredentials) String 

func (m *APICredentials) String() string

func (*APICredentials) Unmarshal 

func (m *APICredentials) Unmarshal(dAtA []byte) error

func (*APICredentials) XXX_DiscardUnknown 

func (m *APICredentials) XXX_DiscardUnknown()

func (*APICredentials) XXX_Marshal 

func (m *APICredentials) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*APICredentials) XXX_Merge 

func (m *APICredentials) XXX_Merge(src proto.Message)

func (*APICredentials) XXX_Size 

func (m *APICredentials) XXX_Size() int

func (*APICredentials) XXX_Unmarshal 

func (m *APICredentials) XXX_Unmarshal(b []byte) error

type APIKey 

type APIKey struct {
	SaslMechanism        string   `` /* 161-byte string literal not displayed */
	HashedSecret         string   `` /* 156-byte string literal not displayed */
	HashFunction         string   `` /* 156-byte string literal not displayed */
	LogicalClusterId     string   `` /* 180-byte string literal not displayed */
	UserId               string   `` /* 126-byte string literal not displayed */
	ServiceAccount       bool     `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*APIKey) Descriptor 

func (*APIKey) Descriptor() ([]byte, []int)

func (*APIKey) GetHashFunction 

func (m *APIKey) GetHashFunction() string

func (*APIKey) GetHashedSecret 

func (m *APIKey) GetHashedSecret() string

func (*APIKey) GetLogicalClusterId 

func (m *APIKey) GetLogicalClusterId() string

func (*APIKey) GetSaslMechanism 

func (m *APIKey) GetSaslMechanism() string

func (*APIKey) GetServiceAccount 

func (m *APIKey) GetServiceAccount() bool

func (*APIKey) GetUserId 

func (m *APIKey) GetUserId() string

func (*APIKey) Marshal 

func (m *APIKey) Marshal() (dAtA []byte, err error)

func (*APIKey) MarshalTo 

func (m *APIKey) MarshalTo(dAtA []byte) (int, error)

func (*APIKey) ProtoMessage 

func (*APIKey) ProtoMessage()

func (*APIKey) Reset 

func (m *APIKey) Reset()

func (*APIKey) Size 

func (m *APIKey) Size() (n int)

func (*APIKey) String 

func (m *APIKey) String() string

func (*APIKey) Unmarshal 

func (m *APIKey) Unmarshal(dAtA []byte) error

func (*APIKey) XXX_DiscardUnknown 

func (m *APIKey) XXX_DiscardUnknown()

func (*APIKey) XXX_Marshal 

func (m *APIKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*APIKey) XXX_Merge 

func (m *APIKey) XXX_Merge(src proto.Message)

func (*APIKey) XXX_Size 

func (m *APIKey) XXX_Size() int

func (*APIKey) XXX_Unmarshal 

func (m *APIKey) XXX_Unmarshal(b []byte) error

type APIKeys 

type APIKeys struct {
	// The keys are the users' api key values.
	Keys                 map[string]*APIKey `` /* 190-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

APIKeys is the data marshaled in secret.Data's "api_key" key-value (see k8s' Secret.Data)

func (*APIKeys) Descriptor 

func (*APIKeys) Descriptor() ([]byte, []int)

func (*APIKeys) GetKeys 

func (m *APIKeys) GetKeys() map[string]*APIKey

func (*APIKeys) Marshal 

func (m *APIKeys) Marshal() (dAtA []byte, err error)

func (*APIKeys) MarshalTo 

func (m *APIKeys) MarshalTo(dAtA []byte) (int, error)

func (*APIKeys) ProtoMessage 

func (*APIKeys) ProtoMessage()

func (*APIKeys) Reset 

func (m *APIKeys) Reset()

func (*APIKeys) Size 

func (m *APIKeys) Size() (n int)

func (*APIKeys) String 

func (m *APIKeys) String() string

func (*APIKeys) Unmarshal 

func (m *APIKeys) Unmarshal(dAtA []byte) error

func (*APIKeys) XXX_DiscardUnknown 

func (m *APIKeys) XXX_DiscardUnknown()

func (*APIKeys) XXX_Marshal 

func (m *APIKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*APIKeys) XXX_Merge 

func (m *APIKeys) XXX_Merge(src proto.Message)

func (*APIKeys) XXX_Size 

func (m *APIKeys) XXX_Size() int

func (*APIKeys) XXX_Unmarshal 

func (m *APIKeys) XXX_Unmarshal(b []byte) error

type Account 

type Account struct {
	Id                   string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	Name                 string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	OrganizationId       int32            `` /* 167-byte string literal not displayed */
	Deactivated          bool             `` /* 131-byte string literal not displayed */
	Created              *types.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified             *types.Timestamp `protobuf:"bytes,7,opt,name=modified,proto3" json:"modified,omitempty" db:"modified,omitempty" url:"modified,omitempty"`
	Config               *AccountConfig   `protobuf:"bytes,8,opt,name=config,proto3" json:"config,omitempty" db:"config,omitempty" url:"config,omitempty"`
	Internal             bool             `protobuf:"varint,9,opt,name=internal,proto3" json:"internal,omitempty" db:"internal,omitempty" url:"internal,omitempty"`
	DeactivatedAt        *types.Timestamp `` /* 162-byte string literal not displayed */
	OrgResourceId        string           `` /* 166-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Account) Descriptor 

func (*Account) Descriptor() ([]byte, []int)

func (*Account) GetConfig 

func (m *Account) GetConfig() *AccountConfig

func (*Account) GetCreated 

func (m *Account) GetCreated() *types.Timestamp

func (*Account) GetDeactivated 

func (m *Account) GetDeactivated() bool

func (*Account) GetDeactivatedAt 

func (m *Account) GetDeactivatedAt() *types.Timestamp

func (*Account) GetId 

func (m *Account) GetId() string

func (*Account) GetInternal 

func (m *Account) GetInternal() bool

func (*Account) GetModified 

func (m *Account) GetModified() *types.Timestamp

func (*Account) GetName 

func (m *Account) GetName() string

func (*Account) GetOrgResourceId 

func (m *Account) GetOrgResourceId() string

func (*Account) GetOrganizationId 

func (m *Account) GetOrganizationId() int32

func (*Account) Marshal 

func (m *Account) Marshal() (dAtA []byte, err error)

func (*Account) MarshalTo 

func (m *Account) MarshalTo(dAtA []byte) (int, error)

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) Reset 

func (m *Account) Reset()

func (*Account) Size 

func (m *Account) Size() (n int)

func (*Account) String 

func (m *Account) String() string

func (*Account) Unmarshal 

func (m *Account) Unmarshal(dAtA []byte) error

func (*Account) XXX_DiscardUnknown 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal 

func (m *Account) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Account) XXX_Merge 

func (m *Account) XXX_Merge(src proto.Message)

func (*Account) XXX_Size 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal 

func (m *Account) XXX_Unmarshal(b []byte) error

type AccountConfig 

type AccountConfig struct {
	MaxKafkaClusters     int32    `` /* 181-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AccountConfig) Descriptor 

func (*AccountConfig) Descriptor() ([]byte, []int)

func (*AccountConfig) GetMaxKafkaClusters 

func (m *AccountConfig) GetMaxKafkaClusters() int32

func (*AccountConfig) Marshal 

func (m *AccountConfig) Marshal() (dAtA []byte, err error)

func (*AccountConfig) MarshalTo 

func (m *AccountConfig) MarshalTo(dAtA []byte) (int, error)

func (*AccountConfig) ProtoMessage 

func (*AccountConfig) ProtoMessage()

func (*AccountConfig) Reset 

func (m *AccountConfig) Reset()

func (*AccountConfig) Size 

func (m *AccountConfig) Size() (n int)

func (*AccountConfig) String 

func (m *AccountConfig) String() string

func (*AccountConfig) Unmarshal 

func (m *AccountConfig) Unmarshal(dAtA []byte) error

func (*AccountConfig) XXX_DiscardUnknown 

func (m *AccountConfig) XXX_DiscardUnknown()

func (*AccountConfig) XXX_Marshal 

func (m *AccountConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountConfig) XXX_Merge 

func (m *AccountConfig) XXX_Merge(src proto.Message)

func (*AccountConfig) XXX_Size 

func (m *AccountConfig) XXX_Size() int

func (*AccountConfig) XXX_Unmarshal 

func (m *AccountConfig) XXX_Unmarshal(b []byte) error

type AccountInterface 

type AccountInterface interface {
	Create(*Account) (*Account, error)
	Get(*Account) (*Account, error)
	List(*Account) ([]*Account, error)
}

Account service allows managing accounts in Confluent Cloud

type AccountMetadata 

type AccountMetadata struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AccountMetadata) Descriptor 

func (*AccountMetadata) Descriptor() ([]byte, []int)

func (*AccountMetadata) GetId 

func (m *AccountMetadata) GetId() string

func (*AccountMetadata) Marshal 

func (m *AccountMetadata) Marshal() (dAtA []byte, err error)

func (*AccountMetadata) MarshalTo 

func (m *AccountMetadata) MarshalTo(dAtA []byte) (int, error)

func (*AccountMetadata) ProtoMessage 

func (*AccountMetadata) ProtoMessage()

func (*AccountMetadata) Reset 

func (m *AccountMetadata) Reset()

func (*AccountMetadata) Scan 

func (t *AccountMetadata) Scan(val interface{}) error

func (*AccountMetadata) Size 

func (m *AccountMetadata) Size() (n int)

func (*AccountMetadata) String 

func (m *AccountMetadata) String() string

func (*AccountMetadata) Unmarshal 

func (m *AccountMetadata) Unmarshal(dAtA []byte) error

func (*AccountMetadata) Value 

func (t *AccountMetadata) Value() (driver.Value, error)

func (*AccountMetadata) XXX_DiscardUnknown 

func (m *AccountMetadata) XXX_DiscardUnknown()

func (*AccountMetadata) XXX_Marshal 

func (m *AccountMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountMetadata) XXX_Merge 

func (m *AccountMetadata) XXX_Merge(src proto.Message)

func (*AccountMetadata) XXX_Size 

func (m *AccountMetadata) XXX_Size() int

func (*AccountMetadata) XXX_Unmarshal 

func (m *AccountMetadata) XXX_Unmarshal(b []byte) error

type AccountService 

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

AccountService provides methods for managing accounts on Confluent Control Plane.

func NewAccountService 

func NewAccountService(client *Client) *AccountService

NewAccountService returns a new AccountService.

func (*AccountService) Create 

func (s *AccountService) Create(account *Account) (*Account, error)

Create creates a new account When Creating a new Account following fields are required name, organization_id

func (*AccountService) Get 

func (s *AccountService) Get(account *Account) (*Account, error)

Get returns details for a given account.

func (*AccountService) List 

func (s *AccountService) List(account *Account) ([]*Account, error)

List returns the accounts that match

type Address 

type Address struct {
	Street1              string   `protobuf:"bytes,1,opt,name=street1,proto3" json:"street1,omitempty" db:"street1,omitempty" url:"street1,omitempty"`
	Street2              string   `protobuf:"bytes,2,opt,name=street2,proto3" json:"street2,omitempty" db:"street2,omitempty" url:"street2,omitempty"`
	City                 string   `protobuf:"bytes,3,opt,name=city,proto3" json:"city,omitempty" db:"city,omitempty" url:"city,omitempty"`
	State                string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty" db:"state,omitempty" url:"state,omitempty"`
	Country              string   `protobuf:"bytes,5,opt,name=country,proto3" json:"country,omitempty" db:"country,omitempty" url:"country,omitempty"`
	Zip                  string   `protobuf:"bytes,6,opt,name=zip,proto3" json:"zip,omitempty" db:"zip,omitempty" url:"zip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Address) Descriptor 

func (*Address) Descriptor() ([]byte, []int)

func (*Address) GetCity 

func (m *Address) GetCity() string

func (*Address) GetCountry 

func (m *Address) GetCountry() string

func (*Address) GetState 

func (m *Address) GetState() string

func (*Address) GetStreet1 

func (m *Address) GetStreet1() string

func (*Address) GetStreet2 

func (m *Address) GetStreet2() string

func (*Address) GetZip 

func (m *Address) GetZip() string

func (*Address) Marshal 

func (m *Address) Marshal() (dAtA []byte, err error)

func (*Address) MarshalTo 

func (m *Address) MarshalTo(dAtA []byte) (int, error)

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) Reset 

func (m *Address) Reset()

func (*Address) Size 

func (m *Address) Size() (n int)

func (*Address) String 

func (m *Address) String() string

func (*Address) Unmarshal 

func (m *Address) Unmarshal(dAtA []byte) error

func (*Address) XXX_DiscardUnknown 

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal 

func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address) XXX_Merge 

func (m *Address) XXX_Merge(src proto.Message)

func (*Address) XXX_Size 

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal 

func (m *Address) XXX_Unmarshal(b []byte) error

type AuditLog 

type AuditLog struct {
	ClusterId                string   `` /* 141-byte string literal not displayed */
	AccountId                string   `` /* 141-byte string literal not displayed */
	ServiceAccountId         int32    `` /* 181-byte string literal not displayed */
	TopicName                string   `` /* 141-byte string literal not displayed */
	ServiceAccountResourceId string   `` /* 224-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{} `json:"-"`
	XXX_unrecognized         []byte   `json:"-"`
	XXX_sizecache            int32    `json:"-"`
}

* Represents the customer-accessible audit log cluster info for the organization

func (*AuditLog) Descriptor 

func (*AuditLog) Descriptor() ([]byte, []int)

func (*AuditLog) GetAccountId 

func (m *AuditLog) GetAccountId() string

func (*AuditLog) GetClusterId 

func (m *AuditLog) GetClusterId() string

func (*AuditLog) GetServiceAccountId 

func (m *AuditLog) GetServiceAccountId() int32

func (*AuditLog) GetServiceAccountResourceId 

func (m *AuditLog) GetServiceAccountResourceId() string

func (*AuditLog) GetTopicName 

func (m *AuditLog) GetTopicName() string

func (*AuditLog) Marshal 

func (m *AuditLog) Marshal() (dAtA []byte, err error)

func (*AuditLog) MarshalTo 

func (m *AuditLog) MarshalTo(dAtA []byte) (int, error)

func (*AuditLog) ProtoMessage 

func (*AuditLog) ProtoMessage()

func (*AuditLog) Reset 

func (m *AuditLog) Reset()

func (*AuditLog) Size 

func (m *AuditLog) Size() (n int)

func (*AuditLog) String 

func (m *AuditLog) String() string

func (*AuditLog) Unmarshal 

func (m *AuditLog) Unmarshal(dAtA []byte) error

func (*AuditLog) XXX_DiscardUnknown 

func (m *AuditLog) XXX_DiscardUnknown()

func (*AuditLog) XXX_Marshal 

func (m *AuditLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuditLog) XXX_Merge 

func (m *AuditLog) XXX_Merge(src proto.Message)

func (*AuditLog) XXX_Size 

func (m *AuditLog) XXX_Size() int

func (*AuditLog) XXX_Unmarshal 

func (m *AuditLog) XXX_Unmarshal(b []byte) error

type Auth 

type Auth interface {
	Login(*AuthenticateRequest) (*AuthenticateReply, error)
	OktaLogin(*AuthenticateRequest) (*AuthenticateReply, error)
	Logout(*AuthenticateRequest) (*AuthenticateReply, error)
	OktaLogout(*AuthenticateRequest) (*AuthenticateReply, error)
	User() (*GetMeReply, error)
}

Auth allows authenticating in Confluent Cloud

type AuthService 

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

AuthService provides methods for authenticating to Confluent Control Plane

func NewAuthService 

func NewAuthService(client *Client) *AuthService

NewAuthService returns a new AuthService.

func (*AuthService) Login 

func (a *AuthService) Login(req *AuthenticateRequest) (*AuthenticateReply, error)

Login attempts to log a user in with an Auth0 ID token, returning either a (CCloud) token or an error.

func (*AuthService) Logout 

func (a *AuthService) Logout(req *AuthenticateRequest) (*AuthenticateReply, error)

Logout attempts to log a user out with an Auth0 ID token.

func (*AuthService) OktaLogin 

func (a *AuthService) OktaLogin(req *AuthenticateRequest) (*AuthenticateReply, error)

func (*AuthService) OktaLogout 

func (a *AuthService) OktaLogout(req *AuthenticateRequest) (*AuthenticateReply, error)

func (*AuthService) User 

func (a *AuthService) User() (*GetMeReply, error)

User returns the AuthConfig for the authenticated user.

type AuthType 

type AuthType int32
const (
	AuthType_AUTH_TYPE_UNKNOWN AuthType = 0
	AuthType_AUTH_TYPE_LOCAL   AuthType = 1
	AuthType_AUTH_TYPE_SSO     AuthType = 2
)

func (AuthType) EnumDescriptor 

func (AuthType) EnumDescriptor() ([]byte, []int)

func (AuthType) String 

func (x AuthType) String() string

type AuthenticateReply 

type AuthenticateReply struct {
	Token                string        `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty" db:"token,omitempty" url:"token,omitempty"`
	Error                *Error        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	User                 *User         `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	Organization         *Organization `` /* 134-byte string literal not displayed */
	RefreshToken         string        `` /* 156-byte string literal not displayed */
	IdentityProvider     string        `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AuthenticateReply) Descriptor 

func (*AuthenticateReply) Descriptor() ([]byte, []int)

func (*AuthenticateReply) GetError 

func (m *AuthenticateReply) GetError() *Error

func (*AuthenticateReply) GetIdentityProvider 

func (m *AuthenticateReply) GetIdentityProvider() string

func (*AuthenticateReply) GetOrganization 

func (m *AuthenticateReply) GetOrganization() *Organization

func (*AuthenticateReply) GetRefreshToken 

func (m *AuthenticateReply) GetRefreshToken() string

func (*AuthenticateReply) GetToken 

func (m *AuthenticateReply) GetToken() string

func (*AuthenticateReply) GetUser 

func (m *AuthenticateReply) GetUser() *User

func (*AuthenticateReply) Marshal 

func (m *AuthenticateReply) Marshal() (dAtA []byte, err error)

func (*AuthenticateReply) MarshalTo 

func (m *AuthenticateReply) MarshalTo(dAtA []byte) (int, error)

func (*AuthenticateReply) ProtoMessage 

func (*AuthenticateReply) ProtoMessage()

func (*AuthenticateReply) Reset 

func (m *AuthenticateReply) Reset()

func (*AuthenticateReply) Size 

func (m *AuthenticateReply) Size() (n int)

func (*AuthenticateReply) String 

func (m *AuthenticateReply) String() string

func (*AuthenticateReply) Unmarshal 

func (m *AuthenticateReply) Unmarshal(dAtA []byte) error

func (*AuthenticateReply) XXX_DiscardUnknown 

func (m *AuthenticateReply) XXX_DiscardUnknown()

func (*AuthenticateReply) XXX_Marshal 

func (m *AuthenticateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthenticateReply) XXX_Merge 

func (m *AuthenticateReply) XXX_Merge(src proto.Message)

func (*AuthenticateReply) XXX_Size 

func (m *AuthenticateReply) XXX_Size() int

func (*AuthenticateReply) XXX_Unmarshal 

func (m *AuthenticateReply) XXX_Unmarshal(b []byte) error

type AuthenticateRequest 

type AuthenticateRequest struct {
	Email                string            `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty" db:"email,omitempty" url:"email,omitempty"`
	Password             string            `` /* 129-byte string literal not displayed */
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	IdToken              string            `` /* 131-byte string literal not displayed */
	ExternalOauthToken   string            `` /* 190-byte string literal not displayed */
	OrgResourceId        string            `` /* 165-byte string literal not displayed */
	IdentityPool         string            `` /* 156-byte string literal not displayed */
	RefreshToken         string            `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*AuthenticateRequest) Descriptor 

func (*AuthenticateRequest) Descriptor() ([]byte, []int)

func (*AuthenticateRequest) GetEmail 

func (m *AuthenticateRequest) GetEmail() string

func (*AuthenticateRequest) GetExternalOauthToken 

func (m *AuthenticateRequest) GetExternalOauthToken() string

func (*AuthenticateRequest) GetIdToken 

func (m *AuthenticateRequest) GetIdToken() string

func (*AuthenticateRequest) GetIdentityPool 

func (m *AuthenticateRequest) GetIdentityPool() string

func (*AuthenticateRequest) GetOrgResourceId 

func (m *AuthenticateRequest) GetOrgResourceId() string

func (*AuthenticateRequest) GetPassword 

func (m *AuthenticateRequest) GetPassword() string

func (*AuthenticateRequest) GetRefreshToken 

func (m *AuthenticateRequest) GetRefreshToken() string

func (*AuthenticateRequest) GetRequestCarrier 

func (m *AuthenticateRequest) GetRequestCarrier() map[string]string

func (*AuthenticateRequest) Marshal 

func (m *AuthenticateRequest) Marshal() (dAtA []byte, err error)

func (*AuthenticateRequest) MarshalTo 

func (m *AuthenticateRequest) MarshalTo(dAtA []byte) (int, error)

func (*AuthenticateRequest) ProtoMessage 

func (*AuthenticateRequest) ProtoMessage()

func (*AuthenticateRequest) Reset 

func (m *AuthenticateRequest) Reset()

func (*AuthenticateRequest) SetRequestCarrier 

func (t *AuthenticateRequest) SetRequestCarrier(request_carrier map[string]string)

func (*AuthenticateRequest) Size 

func (m *AuthenticateRequest) Size() (n int)

func (*AuthenticateRequest) String 

func (m *AuthenticateRequest) String() string

func (*AuthenticateRequest) Unmarshal 

func (m *AuthenticateRequest) Unmarshal(dAtA []byte) error

func (*AuthenticateRequest) XXX_DiscardUnknown 

func (m *AuthenticateRequest) XXX_DiscardUnknown()

func (*AuthenticateRequest) XXX_Marshal 

func (m *AuthenticateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthenticateRequest) XXX_Merge 

func (m *AuthenticateRequest) XXX_Merge(src proto.Message)

func (*AuthenticateRequest) XXX_Size 

func (m *AuthenticateRequest) XXX_Size() int

func (*AuthenticateRequest) XXX_Unmarshal 

func (m *AuthenticateRequest) XXX_Unmarshal(b []byte) error

type AvailabilityZone 

type AvailabilityZone struct {
	// us-west-2
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	// AWS:   zone id
	// GCP:   zone name
	// AZURE: zone name
	ZoneId string `` /* 126-byte string literal not displayed */
	// The internal mothership zone id
	Id                   string           `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	RegionId             string           `` /* 136-byte string literal not displayed */
	SniEnabled           *types.BoolValue `` /* 146-byte string literal not displayed */
	Schedulable          *types.BoolValue `` /* 130-byte string literal not displayed */
	Created              *time.Time       `protobuf:"bytes,8,opt,name=created,proto3,stdtime" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified             *time.Time       `` /* 126-byte string literal not displayed */
	Deactivated          *time.Time       `` /* 139-byte string literal not displayed */
	Realm                string           `protobuf:"bytes,12,opt,name=realm,proto3" json:"realm,omitempty" db:"realm,omitempty" url:"realm,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*AvailabilityZone) Descriptor 

func (*AvailabilityZone) Descriptor() ([]byte, []int)

func (*AvailabilityZone) GetCreated 

func (m *AvailabilityZone) GetCreated() *time.Time

func (*AvailabilityZone) GetDeactivated 

func (m *AvailabilityZone) GetDeactivated() *time.Time

func (*AvailabilityZone) GetId 

func (m *AvailabilityZone) GetId() string

func (*AvailabilityZone) GetModified 

func (m *AvailabilityZone) GetModified() *time.Time

func (*AvailabilityZone) GetName 

func (m *AvailabilityZone) GetName() string

func (*AvailabilityZone) GetRealm 

func (m *AvailabilityZone) GetRealm() string

func (*AvailabilityZone) GetRegionId 

func (m *AvailabilityZone) GetRegionId() string

func (*AvailabilityZone) GetSchedulable 

func (m *AvailabilityZone) GetSchedulable() *types.BoolValue

func (*AvailabilityZone) GetSniEnabled 

func (m *AvailabilityZone) GetSniEnabled() *types.BoolValue

func (*AvailabilityZone) GetZoneId 

func (m *AvailabilityZone) GetZoneId() string

func (*AvailabilityZone) Marshal 

func (m *AvailabilityZone) Marshal() (dAtA []byte, err error)

func (*AvailabilityZone) MarshalTo 

func (m *AvailabilityZone) MarshalTo(dAtA []byte) (int, error)

func (*AvailabilityZone) ProtoMessage 

func (*AvailabilityZone) ProtoMessage()

func (*AvailabilityZone) Reset 

func (m *AvailabilityZone) Reset()

func (*AvailabilityZone) Size 

func (m *AvailabilityZone) Size() (n int)

func (*AvailabilityZone) String 

func (m *AvailabilityZone) String() string

func (*AvailabilityZone) Unmarshal 

func (m *AvailabilityZone) Unmarshal(dAtA []byte) error

func (*AvailabilityZone) XXX_DiscardUnknown 

func (m *AvailabilityZone) XXX_DiscardUnknown()

func (*AvailabilityZone) XXX_Marshal 

func (m *AvailabilityZone) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvailabilityZone) XXX_Merge 

func (m *AvailabilityZone) XXX_Merge(src proto.Message)

func (*AvailabilityZone) XXX_Size 

func (m *AvailabilityZone) XXX_Size() int

func (*AvailabilityZone) XXX_Unmarshal 

func (m *AvailabilityZone) XXX_Unmarshal(b []byte) error

type Billing 

type Billing interface {
	GetPriceTable(*Organization, string) (*PriceTable, error)
	GetPaymentInfo(*Organization) (*Card, error)
	UpdatePaymentInfo(*Organization, string) error
	ClaimPromoCode(*Organization, string) (*PromoCodeClaim, error)
	GetClaimedPromoCodes(*Organization, bool) ([]*PromoCodeClaim, error)
}

Billing service allows getting billing information for an org in Confluent Cloud

type BillingInterval 

type BillingInterval int32
const (
	BillingInterval_MONTHLY  BillingInterval = 0
	BillingInterval_ANNUALLY BillingInterval = 1
)

func (BillingInterval) EnumDescriptor 

func (BillingInterval) EnumDescriptor() ([]byte, []int)

func (BillingInterval) String 

func (x BillingInterval) String() string

type BillingMethod 

type BillingMethod int32
const (
	BillingMethod_STRIPE      BillingMethod = 0
	BillingMethod_MANUAL      BillingMethod = 1
	BillingMethod_GCP         BillingMethod = 2
	BillingMethod_SKIP        BillingMethod = 3
	BillingMethod_MARKETPLACE BillingMethod = 4
	BillingMethod_NONE        BillingMethod = 5
)

func (BillingMethod) EnumDescriptor 

func (BillingMethod) EnumDescriptor() ([]byte, []int)

func (BillingMethod) String 

func (x BillingMethod) String() string

type BillingService 

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

func NewBillingService 

func NewBillingService(client *Client) *BillingService

func (*BillingService) ClaimPromoCode 

func (o *BillingService) ClaimPromoCode(org *Organization, code string) (*PromoCodeClaim, error)

func (*BillingService) GetClaimedPromoCodes 

func (o *BillingService) GetClaimedPromoCodes(org *Organization, excludeExpired bool) ([]*PromoCodeClaim, error)

func (*BillingService) GetPaymentInfo 

func (o *BillingService) GetPaymentInfo(org *Organization) (*Card, error)

func (*BillingService) GetPriceTable 

func (o *BillingService) GetPriceTable(org *Organization, product string) (*PriceTable, error)

func (*BillingService) UpdatePaymentInfo 

func (o *BillingService) UpdatePaymentInfo(org *Organization, stripeToken string) error

type Card 

type Card struct {
	Cardholder           string   `` /* 126-byte string literal not displayed */
	Brand                string   `protobuf:"bytes,2,opt,name=brand,proto3" json:"brand,omitempty" db:"brand,omitempty" url:"brand,omitempty"`
	Last4                string   `protobuf:"bytes,3,opt,name=last4,proto3" json:"last4,omitempty" db:"last4,omitempty" url:"last4,omitempty"`
	ExpMonth             string   `` /* 136-byte string literal not displayed */
	ExpYear              string   `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Card) Descriptor 

func (*Card) Descriptor() ([]byte, []int)

func (*Card) GetBrand 

func (m *Card) GetBrand() string

func (*Card) GetCardholder 

func (m *Card) GetCardholder() string

func (*Card) GetExpMonth 

func (m *Card) GetExpMonth() string

func (*Card) GetExpYear 

func (m *Card) GetExpYear() string

func (*Card) GetLast4 

func (m *Card) GetLast4() string

func (*Card) Marshal 

func (m *Card) Marshal() (dAtA []byte, err error)

func (*Card) MarshalTo 

func (m *Card) MarshalTo(dAtA []byte) (int, error)

func (*Card) ProtoMessage 

func (*Card) ProtoMessage()

func (*Card) Reset 

func (m *Card) Reset()

func (*Card) Size 

func (m *Card) Size() (n int)

func (*Card) String 

func (m *Card) String() string

func (*Card) Unmarshal 

func (m *Card) Unmarshal(dAtA []byte) error

func (*Card) XXX_DiscardUnknown 

func (m *Card) XXX_DiscardUnknown()

func (*Card) XXX_Marshal 

func (m *Card) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Card) XXX_Merge 

func (m *Card) XXX_Merge(src proto.Message)

func (*Card) XXX_Size 

func (m *Card) XXX_Size() int

func (*Card) XXX_Unmarshal 

func (m *Card) XXX_Unmarshal(b []byte) error

type ClaimPromoCodeReply 

type ClaimPromoCodeReply struct {
	Claim                *PromoCodeClaim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim,omitempty" db:"claim,omitempty" url:"claim,omitempty"`
	Error                *Error          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ClaimPromoCodeReply) Descriptor 

func (*ClaimPromoCodeReply) Descriptor() ([]byte, []int)

func (*ClaimPromoCodeReply) GetClaim 

func (m *ClaimPromoCodeReply) GetClaim() *PromoCodeClaim

func (*ClaimPromoCodeReply) GetError 

func (m *ClaimPromoCodeReply) GetError() *Error

func (*ClaimPromoCodeReply) Marshal 

func (m *ClaimPromoCodeReply) Marshal() (dAtA []byte, err error)

func (*ClaimPromoCodeReply) MarshalTo 

func (m *ClaimPromoCodeReply) MarshalTo(dAtA []byte) (int, error)

func (*ClaimPromoCodeReply) ProtoMessage 

func (*ClaimPromoCodeReply) ProtoMessage()

func (*ClaimPromoCodeReply) Reset 

func (m *ClaimPromoCodeReply) Reset()

func (*ClaimPromoCodeReply) Size 

func (m *ClaimPromoCodeReply) Size() (n int)

func (*ClaimPromoCodeReply) String 

func (m *ClaimPromoCodeReply) String() string

func (*ClaimPromoCodeReply) Unmarshal 

func (m *ClaimPromoCodeReply) Unmarshal(dAtA []byte) error

func (*ClaimPromoCodeReply) XXX_DiscardUnknown 

func (m *ClaimPromoCodeReply) XXX_DiscardUnknown()

func (*ClaimPromoCodeReply) XXX_Marshal 

func (m *ClaimPromoCodeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClaimPromoCodeReply) XXX_Merge 

func (m *ClaimPromoCodeReply) XXX_Merge(src proto.Message)

func (*ClaimPromoCodeReply) XXX_Size 

func (m *ClaimPromoCodeReply) XXX_Size() int

func (*ClaimPromoCodeReply) XXX_Unmarshal 

func (m *ClaimPromoCodeReply) XXX_Unmarshal(b []byte) error

type ClaimPromoCodeRequest 

type ClaimPromoCodeRequest struct {
	OrgId                int32             `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty" db:"org_id,omitempty" url:"org_id,omitempty"`
	Code                 string            `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty" db:"code,omitempty" url:"code,omitempty"`
	ClaimedBy            int32             `` /* 142-byte string literal not displayed */
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

promo code api object for users

func (*ClaimPromoCodeRequest) Descriptor 

func (*ClaimPromoCodeRequest) Descriptor() ([]byte, []int)

func (*ClaimPromoCodeRequest) GetClaimedBy 

func (m *ClaimPromoCodeRequest) GetClaimedBy() int32

func (*ClaimPromoCodeRequest) GetCode 

func (m *ClaimPromoCodeRequest) GetCode() string

func (*ClaimPromoCodeRequest) GetOrgId 

func (m *ClaimPromoCodeRequest) GetOrgId() int32

func (*ClaimPromoCodeRequest) GetRequestCarrier 

func (m *ClaimPromoCodeRequest) GetRequestCarrier() map[string]string

func (*ClaimPromoCodeRequest) Marshal 

func (m *ClaimPromoCodeRequest) Marshal() (dAtA []byte, err error)

func (*ClaimPromoCodeRequest) MarshalTo 

func (m *ClaimPromoCodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClaimPromoCodeRequest) ProtoMessage 

func (*ClaimPromoCodeRequest) ProtoMessage()

func (*ClaimPromoCodeRequest) Reset 

func (m *ClaimPromoCodeRequest) Reset()

func (*ClaimPromoCodeRequest) SetRequestCarrier 

func (t *ClaimPromoCodeRequest) SetRequestCarrier(request_carrier map[string]string)

func (*ClaimPromoCodeRequest) Size 

func (m *ClaimPromoCodeRequest) Size() (n int)

func (*ClaimPromoCodeRequest) String 

func (m *ClaimPromoCodeRequest) String() string

func (*ClaimPromoCodeRequest) Unmarshal 

func (m *ClaimPromoCodeRequest) Unmarshal(dAtA []byte) error

func (*ClaimPromoCodeRequest) XXX_DiscardUnknown 

func (m *ClaimPromoCodeRequest) XXX_DiscardUnknown()

func (*ClaimPromoCodeRequest) XXX_Marshal 

func (m *ClaimPromoCodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClaimPromoCodeRequest) XXX_Merge 

func (m *ClaimPromoCodeRequest) XXX_Merge(src proto.Message)

func (*ClaimPromoCodeRequest) XXX_Size 

func (m *ClaimPromoCodeRequest) XXX_Size() int

func (*ClaimPromoCodeRequest) XXX_Unmarshal 

func (m *ClaimPromoCodeRequest) XXX_Unmarshal(b []byte) error

type Client 

type Client struct {
	*Params

	Account             AccountInterface
	Auth                Auth
	Billing             Billing
	EnvironmentMetadata EnvironmentMetadata
	ExternalIdentity    ExternalIdentity
	Growth              Growth
	SchemaRegistry      SchemaRegistry
	Signup              Signup
	User                UserInterface
	// contains filtered or unexported fields
}

Client represents the Confluent SDK client.

func NewClient 

func NewClient(p *Params) *Client

NewClient creates a Confluent SDK client.

func NewClientWithJWT 

func NewClientWithJWT(ctx context.Context, jwt string, p *Params) *Client

NewClientWithJWT creates a Confluent SDK client which authenticates with the given JSON Web Token (JWT).

type CloudMetadata 

type CloudMetadata struct {
	Id                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	Regions              []*Region          `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty" db:"regions,omitempty" url:"regions,omitempty"`
	Name                 string             `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	Accounts             []*AccountMetadata `protobuf:"bytes,4,rep,name=accounts,proto3" json:"accounts,omitempty" db:"accounts,omitempty" url:"accounts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CloudMetadata) Descriptor 

func (*CloudMetadata) Descriptor() ([]byte, []int)

func (*CloudMetadata) GetAccounts 

func (m *CloudMetadata) GetAccounts() []*AccountMetadata

func (*CloudMetadata) GetId 

func (m *CloudMetadata) GetId() string

func (*CloudMetadata) GetName 

func (m *CloudMetadata) GetName() string

func (*CloudMetadata) GetRegions 

func (m *CloudMetadata) GetRegions() []*Region

func (*CloudMetadata) Marshal 

func (m *CloudMetadata) Marshal() (dAtA []byte, err error)

func (*CloudMetadata) MarshalTo 

func (m *CloudMetadata) MarshalTo(dAtA []byte) (int, error)

func (*CloudMetadata) ProtoMessage 

func (*CloudMetadata) ProtoMessage()

func (*CloudMetadata) Reset 

func (m *CloudMetadata) Reset()

func (*CloudMetadata) Size 

func (m *CloudMetadata) Size() (n int)

func (*CloudMetadata) String 

func (m *CloudMetadata) String() string

func (*CloudMetadata) Unmarshal 

func (m *CloudMetadata) Unmarshal(dAtA []byte) error

func (*CloudMetadata) XXX_DiscardUnknown 

func (m *CloudMetadata) XXX_DiscardUnknown()

func (*CloudMetadata) XXX_Marshal 

func (m *CloudMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloudMetadata) XXX_Merge 

func (m *CloudMetadata) XXX_Merge(src proto.Message)

func (*CloudMetadata) XXX_Size 

func (m *CloudMetadata) XXX_Size() int

func (*CloudMetadata) XXX_Unmarshal 

func (m *CloudMetadata) XXX_Unmarshal(b []byte) error

type ClusterStatus 

type ClusterStatus int32
const (
	ClusterStatus_PROVISIONING      ClusterStatus = 0
	ClusterStatus_UP                ClusterStatus = 1
	ClusterStatus_DOWN              ClusterStatus = 2
	ClusterStatus_DELETING          ClusterStatus = 3
	ClusterStatus_DELETED           ClusterStatus = 4
	ClusterStatus_EXPANSION_PENDING ClusterStatus = 5
	ClusterStatus_EXPANDING         ClusterStatus = 6
	ClusterStatus_SHRINK_PENDING    ClusterStatus = 7
	ClusterStatus_SHRINKING         ClusterStatus = 8
	ClusterStatus_STORAGE_EXPANDING ClusterStatus = 9
)

func (ClusterStatus) EnumDescriptor 

func (ClusterStatus) EnumDescriptor() ([]byte, []int)

func (ClusterStatus) String 

func (x ClusterStatus) String() string

type CreateAccountReply 

type CreateAccountReply struct {
	Account              *Account `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty" db:"account,omitempty" url:"account,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateAccountReply) Descriptor 

func (*CreateAccountReply) Descriptor() ([]byte, []int)

func (*CreateAccountReply) GetAccount 

func (m *CreateAccountReply) GetAccount() *Account

func (*CreateAccountReply) GetError 

func (m *CreateAccountReply) GetError() *Error

func (*CreateAccountReply) Marshal 

func (m *CreateAccountReply) Marshal() (dAtA []byte, err error)

func (*CreateAccountReply) MarshalTo 

func (m *CreateAccountReply) MarshalTo(dAtA []byte) (int, error)

func (*CreateAccountReply) ProtoMessage 

func (*CreateAccountReply) ProtoMessage()

func (*CreateAccountReply) Reset 

func (m *CreateAccountReply) Reset()

func (*CreateAccountReply) Size 

func (m *CreateAccountReply) Size() (n int)

func (*CreateAccountReply) String 

func (m *CreateAccountReply) String() string

func (*CreateAccountReply) Unmarshal 

func (m *CreateAccountReply) Unmarshal(dAtA []byte) error

func (*CreateAccountReply) XXX_DiscardUnknown 

func (m *CreateAccountReply) XXX_DiscardUnknown()

func (*CreateAccountReply) XXX_Marshal 

func (m *CreateAccountReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateAccountReply) XXX_Merge 

func (m *CreateAccountReply) XXX_Merge(src proto.Message)

func (*CreateAccountReply) XXX_Size 

func (m *CreateAccountReply) XXX_Size() int

func (*CreateAccountReply) XXX_Unmarshal 

func (m *CreateAccountReply) XXX_Unmarshal(b []byte) error

type CreateAccountRequest 

type CreateAccountRequest struct {
	Account              *Account          `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty" db:"account,omitempty" url:"account,omitempty"`
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateAccountRequest) Descriptor 

func (*CreateAccountRequest) Descriptor() ([]byte, []int)

func (*CreateAccountRequest) GetAccount 

func (m *CreateAccountRequest) GetAccount() *Account

func (*CreateAccountRequest) GetRequestCarrier 

func (m *CreateAccountRequest) GetRequestCarrier() map[string]string

func (*CreateAccountRequest) Marshal 

func (m *CreateAccountRequest) Marshal() (dAtA []byte, err error)

func (*CreateAccountRequest) MarshalTo 

func (m *CreateAccountRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateAccountRequest) ProtoMessage 

func (*CreateAccountRequest) ProtoMessage()

func (*CreateAccountRequest) Reset 

func (m *CreateAccountRequest) Reset()

func (*CreateAccountRequest) SetRequestCarrier 

func (t *CreateAccountRequest) SetRequestCarrier(request_carrier map[string]string)

func (*CreateAccountRequest) Size 

func (m *CreateAccountRequest) Size() (n int)

func (*CreateAccountRequest) String 

func (m *CreateAccountRequest) String() string

func (*CreateAccountRequest) Unmarshal 

func (m *CreateAccountRequest) Unmarshal(dAtA []byte) error

func (*CreateAccountRequest) XXX_DiscardUnknown 

func (m *CreateAccountRequest) XXX_DiscardUnknown()

func (*CreateAccountRequest) XXX_Marshal 

func (m *CreateAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateAccountRequest) XXX_Merge 

func (m *CreateAccountRequest) XXX_Merge(src proto.Message)

func (*CreateAccountRequest) XXX_Size 

func (m *CreateAccountRequest) XXX_Size() int

func (*CreateAccountRequest) XXX_Unmarshal 

func (m *CreateAccountRequest) XXX_Unmarshal(b []byte) error

type CreateConnectAuthTokenReply 

type CreateConnectAuthTokenReply struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty" db:"token,omitempty" url:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateConnectAuthTokenReply) Descriptor 

func (*CreateConnectAuthTokenReply) Descriptor() ([]byte, []int)

func (*CreateConnectAuthTokenReply) GetError 

func (m *CreateConnectAuthTokenReply) GetError() *Error

func (*CreateConnectAuthTokenReply) GetToken 

func (m *CreateConnectAuthTokenReply) GetToken() string

func (*CreateConnectAuthTokenReply) Marshal 

func (m *CreateConnectAuthTokenReply) Marshal() (dAtA []byte, err error)

func (*CreateConnectAuthTokenReply) MarshalTo 

func (m *CreateConnectAuthTokenReply) MarshalTo(dAtA []byte) (int, error)

func (*CreateConnectAuthTokenReply) ProtoMessage 

func (*CreateConnectAuthTokenReply) ProtoMessage()

func (*CreateConnectAuthTokenReply) Reset 

func (m *CreateConnectAuthTokenReply) Reset()

func (*CreateConnectAuthTokenReply) Size 

func (m *CreateConnectAuthTokenReply) Size() (n int)

func (*CreateConnectAuthTokenReply) String 

func (m *CreateConnectAuthTokenReply) String() string

func (*CreateConnectAuthTokenReply) Unmarshal 

func (m *CreateConnectAuthTokenReply) Unmarshal(dAtA []byte) error

func (*CreateConnectAuthTokenReply) XXX_DiscardUnknown 

func (m *CreateConnectAuthTokenReply) XXX_DiscardUnknown()

func (*CreateConnectAuthTokenReply) XXX_Marshal 

func (m *CreateConnectAuthTokenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateConnectAuthTokenReply) XXX_Merge 

func (m *CreateConnectAuthTokenReply) XXX_Merge(src proto.Message)

func (*CreateConnectAuthTokenReply) XXX_Size 

func (m *CreateConnectAuthTokenReply) XXX_Size() int

func (*CreateConnectAuthTokenReply) XXX_Unmarshal 

func (m *CreateConnectAuthTokenReply) XXX_Unmarshal(b []byte) error

type CreateDecisionEngineAuthTokenReply 

type CreateDecisionEngineAuthTokenReply struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty" db:"token,omitempty" url:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDecisionEngineAuthTokenReply) Descriptor 

func (*CreateDecisionEngineAuthTokenReply) Descriptor() ([]byte, []int)

func (*CreateDecisionEngineAuthTokenReply) GetError 

func (m *CreateDecisionEngineAuthTokenReply) GetError() *Error

func (*CreateDecisionEngineAuthTokenReply) GetToken 

func (m *CreateDecisionEngineAuthTokenReply) GetToken() string

func (*CreateDecisionEngineAuthTokenReply) Marshal 

func (m *CreateDecisionEngineAuthTokenReply) Marshal() (dAtA []byte, err error)

func (*CreateDecisionEngineAuthTokenReply) MarshalTo 

func (m *CreateDecisionEngineAuthTokenReply) MarshalTo(dAtA []byte) (int, error)

func (*CreateDecisionEngineAuthTokenReply) ProtoMessage 

func (*CreateDecisionEngineAuthTokenReply) ProtoMessage()

func (*CreateDecisionEngineAuthTokenReply) Reset 

func (m *CreateDecisionEngineAuthTokenReply) Reset()

func (*CreateDecisionEngineAuthTokenReply) Size 

func (m *CreateDecisionEngineAuthTokenReply) Size() (n int)

func (*CreateDecisionEngineAuthTokenReply) String 

func (m *CreateDecisionEngineAuthTokenReply) String() string

func (*CreateDecisionEngineAuthTokenReply) Unmarshal 

func (m *CreateDecisionEngineAuthTokenReply) Unmarshal(dAtA []byte) error

func (*CreateDecisionEngineAuthTokenReply) XXX_DiscardUnknown 

func (m *CreateDecisionEngineAuthTokenReply) XXX_DiscardUnknown()

func (*CreateDecisionEngineAuthTokenReply) XXX_Marshal 

func (m *CreateDecisionEngineAuthTokenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDecisionEngineAuthTokenReply) XXX_Merge 

func (m *CreateDecisionEngineAuthTokenReply) XXX_Merge(src proto.Message)

func (*CreateDecisionEngineAuthTokenReply) XXX_Size 

func (m *CreateDecisionEngineAuthTokenReply) XXX_Size() int

func (*CreateDecisionEngineAuthTokenReply) XXX_Unmarshal 

func (m *CreateDecisionEngineAuthTokenReply) XXX_Unmarshal(b []byte) error

type CreateEmailVerificationRequest 

type CreateEmailVerificationRequest struct {
	// Only username is required
	Credentials          *Credentials      `` /* 130-byte string literal not displayed */
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateEmailVerificationRequest) Descriptor 

func (*CreateEmailVerificationRequest) Descriptor() ([]byte, []int)

func (*CreateEmailVerificationRequest) GetCredentials 

func (m *CreateEmailVerificationRequest) GetCredentials() *Credentials

func (*CreateEmailVerificationRequest) GetRequestCarrier 

func (m *CreateEmailVerificationRequest) GetRequestCarrier() map[string]string

func (*CreateEmailVerificationRequest) Marshal 

func (m *CreateEmailVerificationRequest) Marshal() (dAtA []byte, err error)

func (*CreateEmailVerificationRequest) MarshalTo 

func (m *CreateEmailVerificationRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateEmailVerificationRequest) ProtoMessage 

func (*CreateEmailVerificationRequest) ProtoMessage()

func (*CreateEmailVerificationRequest) Reset 

func (m *CreateEmailVerificationRequest) Reset()

func (*CreateEmailVerificationRequest) SetRequestCarrier 

func (t *CreateEmailVerificationRequest) SetRequestCarrier(request_carrier map[string]string)

func (*CreateEmailVerificationRequest) Size 

func (m *CreateEmailVerificationRequest) Size() (n int)

func (*CreateEmailVerificationRequest) String 

func (m *CreateEmailVerificationRequest) String() string

func (*CreateEmailVerificationRequest) Unmarshal 

func (m *CreateEmailVerificationRequest) Unmarshal(dAtA []byte) error

func (*CreateEmailVerificationRequest) XXX_DiscardUnknown 

func (m *CreateEmailVerificationRequest) XXX_DiscardUnknown()

func (*CreateEmailVerificationRequest) XXX_Marshal 

func (m *CreateEmailVerificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateEmailVerificationRequest) XXX_Merge 

func (m *CreateEmailVerificationRequest) XXX_Merge(src proto.Message)

func (*CreateEmailVerificationRequest) XXX_Size 

func (m *CreateEmailVerificationRequest) XXX_Size() int

func (*CreateEmailVerificationRequest) XXX_Unmarshal 

func (m *CreateEmailVerificationRequest) XXX_Unmarshal(b []byte) error

type CreateExternalIdentityRequest 

type CreateExternalIdentityRequest struct {
	AccountId            string   `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	Cloud                string   `protobuf:"bytes,2,opt,name=cloud,proto3" json:"cloud,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateExternalIdentityRequest) GetAccountId 

func (m *CreateExternalIdentityRequest) GetAccountId() string

func (*CreateExternalIdentityRequest) GetCloud 

func (m *CreateExternalIdentityRequest) GetCloud() string

func (*CreateExternalIdentityRequest) ProtoMessage 

func (*CreateExternalIdentityRequest) ProtoMessage()

func (*CreateExternalIdentityRequest) Reset 

func (m *CreateExternalIdentityRequest) Reset()

func (*CreateExternalIdentityRequest) String 

func (m *CreateExternalIdentityRequest) String() string

type CreateExternalIdentityResponse 

type CreateExternalIdentityResponse struct {
	IdentityName         string   `protobuf:"bytes,1,opt,name=identity_name,json=identityName,proto3" json:"identity_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateExternalIdentityResponse) GetIdentityName 

func (m *CreateExternalIdentityResponse) GetIdentityName() string

func (*CreateExternalIdentityResponse) ProtoMessage 

func (*CreateExternalIdentityResponse) ProtoMessage()

func (*CreateExternalIdentityResponse) Reset 

func (m *CreateExternalIdentityResponse) Reset()

func (*CreateExternalIdentityResponse) String 

func (m *CreateExternalIdentityResponse) String() string

type CreateSchemaRegistryClusterReply 

type CreateSchemaRegistryClusterReply struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	// {"field name": "err msg"}
	ValidationErrors     map[string]string      `` /* 264-byte string literal not displayed */
	Cluster              *SchemaRegistryCluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	Credentials          *APICredentials        `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CreateSchemaRegistryClusterReply) Descriptor 

func (*CreateSchemaRegistryClusterReply) Descriptor() ([]byte, []int)

func (*CreateSchemaRegistryClusterReply) GetCluster 

func (m *CreateSchemaRegistryClusterReply) GetCluster() *SchemaRegistryCluster

func (*CreateSchemaRegistryClusterReply) GetCredentials 

func (m *CreateSchemaRegistryClusterReply) GetCredentials() *APICredentials

func (*CreateSchemaRegistryClusterReply) GetError 

func (m *CreateSchemaRegistryClusterReply) GetError() *Error

func (*CreateSchemaRegistryClusterReply) GetValidationErrors 

func (m *CreateSchemaRegistryClusterReply) GetValidationErrors() map[string]string

func (*CreateSchemaRegistryClusterReply) Marshal 

func (m *CreateSchemaRegistryClusterReply) Marshal() (dAtA []byte, err error)

func (*CreateSchemaRegistryClusterReply) MarshalTo 

func (m *CreateSchemaRegistryClusterReply) MarshalTo(dAtA []byte) (int, error)

func (*CreateSchemaRegistryClusterReply) ProtoMessage 

func (*CreateSchemaRegistryClusterReply) ProtoMessage()

func (*CreateSchemaRegistryClusterReply) Reset 

func (m *CreateSchemaRegistryClusterReply) Reset()

func (*CreateSchemaRegistryClusterReply) Size 

func (m *CreateSchemaRegistryClusterReply) Size() (n int)

func (*CreateSchemaRegistryClusterReply) String 

func (m *CreateSchemaRegistryClusterReply) String() string

func (*CreateSchemaRegistryClusterReply) Unmarshal 

func (m *CreateSchemaRegistryClusterReply) Unmarshal(dAtA []byte) error

func (*CreateSchemaRegistryClusterReply) XXX_DiscardUnknown 

func (m *CreateSchemaRegistryClusterReply) XXX_DiscardUnknown()

func (*CreateSchemaRegistryClusterReply) XXX_Marshal 

func (m *CreateSchemaRegistryClusterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSchemaRegistryClusterReply) XXX_Merge 

func (m *CreateSchemaRegistryClusterReply) XXX_Merge(src proto.Message)

func (*CreateSchemaRegistryClusterReply) XXX_Size 

func (m *CreateSchemaRegistryClusterReply) XXX_Size() int

func (*CreateSchemaRegistryClusterReply) XXX_Unmarshal 

func (m *CreateSchemaRegistryClusterReply) XXX_Unmarshal(b []byte) error

type CreateSchemaRegistryClusterRequest 

type CreateSchemaRegistryClusterRequest struct {
	Config               *SchemaRegistryClusterConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty" db:"config,omitempty" url:"config,omitempty"`
	RequestCarrier       map[string]string            `` /* 265-byte string literal not displayed */
	Cluster              *SchemaRegistryCluster       `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*CreateSchemaRegistryClusterRequest) Descriptor 

func (*CreateSchemaRegistryClusterRequest) Descriptor() ([]byte, []int)

func (*CreateSchemaRegistryClusterRequest) GetCluster 

func (m *CreateSchemaRegistryClusterRequest) GetCluster() *SchemaRegistryCluster

func (*CreateSchemaRegistryClusterRequest) GetConfig 

func (m *CreateSchemaRegistryClusterRequest) GetConfig() *SchemaRegistryClusterConfig

func (*CreateSchemaRegistryClusterRequest) GetRequestCarrier 

func (m *CreateSchemaRegistryClusterRequest) GetRequestCarrier() map[string]string

func (*CreateSchemaRegistryClusterRequest) Marshal 

func (m *CreateSchemaRegistryClusterRequest) Marshal() (dAtA []byte, err error)

func (*CreateSchemaRegistryClusterRequest) MarshalTo 

func (m *CreateSchemaRegistryClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateSchemaRegistryClusterRequest) ProtoMessage 

func (*CreateSchemaRegistryClusterRequest) ProtoMessage()

func (*CreateSchemaRegistryClusterRequest) Reset 

func (m *CreateSchemaRegistryClusterRequest) Reset()

func (*CreateSchemaRegistryClusterRequest) SetRequestCarrier 

func (t *CreateSchemaRegistryClusterRequest) SetRequestCarrier(request_carrier map[string]string)

func (*CreateSchemaRegistryClusterRequest) Size 

func (m *CreateSchemaRegistryClusterRequest) Size() (n int)

func (*CreateSchemaRegistryClusterRequest) String 

func (m *CreateSchemaRegistryClusterRequest) String() string

func (*CreateSchemaRegistryClusterRequest) Unmarshal 

func (m *CreateSchemaRegistryClusterRequest) Unmarshal(dAtA []byte) error

func (*CreateSchemaRegistryClusterRequest) XXX_DiscardUnknown 

func (m *CreateSchemaRegistryClusterRequest) XXX_DiscardUnknown()

func (*CreateSchemaRegistryClusterRequest) XXX_Marshal 

func (m *CreateSchemaRegistryClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSchemaRegistryClusterRequest) XXX_Merge 

func (m *CreateSchemaRegistryClusterRequest) XXX_Merge(src proto.Message)

func (*CreateSchemaRegistryClusterRequest) XXX_Size 

func (m *CreateSchemaRegistryClusterRequest) XXX_Size() int

func (*CreateSchemaRegistryClusterRequest) XXX_Unmarshal 

func (m *CreateSchemaRegistryClusterRequest) XXX_Unmarshal(b []byte) error

type Credentials 

type Credentials struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty" db:"username,omitempty" url:"username,omitempty"`
	Password             string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Credentials) Descriptor 

func (*Credentials) Descriptor() ([]byte, []int)

func (*Credentials) GetPassword 

func (m *Credentials) GetPassword() string

func (*Credentials) GetUsername 

func (m *Credentials) GetUsername() string

func (*Credentials) Marshal 

func (m *Credentials) Marshal() (dAtA []byte, err error)

func (*Credentials) MarshalTo 

func (m *Credentials) MarshalTo(dAtA []byte) (int, error)

func (*Credentials) ProtoMessage 

func (*Credentials) ProtoMessage()

func (*Credentials) Reset 

func (m *Credentials) Reset()

func (*Credentials) Size 

func (m *Credentials) Size() (n int)

func (*Credentials) String 

func (m *Credentials) String() string

func (*Credentials) Unmarshal 

func (m *Credentials) Unmarshal(dAtA []byte) error

func (*Credentials) XXX_DiscardUnknown 

func (m *Credentials) XXX_DiscardUnknown()

func (*Credentials) XXX_Marshal 

func (m *Credentials) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Credentials) XXX_Merge 

func (m *Credentials) XXX_Merge(src proto.Message)

func (*Credentials) XXX_Size 

func (m *Credentials) XXX_Size() int

func (*Credentials) XXX_Unmarshal 

func (m *Credentials) XXX_Unmarshal(b []byte) error

type DataBalancerConfig 

type DataBalancerConfig struct {
	ReplicationThrottleBytesPerSec  *types.Int64Value  `` /* 258-byte string literal not displayed */
	SelfHealingGoalViolationEnabled *types.BoolValue   `` /* 263-byte string literal not displayed */
	MaxVolumeThroughputMbPerSec     *types.Int32Value  `` /* 247-byte string literal not displayed */
	WriteThroughputMultiplier       *types.DoubleValue `` /* 225-byte string literal not displayed */
	ReadThroughputMultiplier        *types.DoubleValue `` /* 220-byte string literal not displayed */
	XXX_NoUnkeyedLiteral            struct{}           `json:"-"`
	XXX_unrecognized                []byte             `json:"-"`
	XXX_sizecache                   int32              `json:"-"`
}

func (*DataBalancerConfig) Descriptor 

func (*DataBalancerConfig) Descriptor() ([]byte, []int)

func (*DataBalancerConfig) GetMaxVolumeThroughputMbPerSec 

func (m *DataBalancerConfig) GetMaxVolumeThroughputMbPerSec() *types.Int32Value

func (*DataBalancerConfig) GetReadThroughputMultiplier 

func (m *DataBalancerConfig) GetReadThroughputMultiplier() *types.DoubleValue

func (*DataBalancerConfig) GetReplicationThrottleBytesPerSec 

func (m *DataBalancerConfig) GetReplicationThrottleBytesPerSec() *types.Int64Value

func (*DataBalancerConfig) GetSelfHealingGoalViolationEnabled 

func (m *DataBalancerConfig) GetSelfHealingGoalViolationEnabled() *types.BoolValue

func (*DataBalancerConfig) GetWriteThroughputMultiplier 

func (m *DataBalancerConfig) GetWriteThroughputMultiplier() *types.DoubleValue

func (*DataBalancerConfig) Marshal 

func (m *DataBalancerConfig) Marshal() (dAtA []byte, err error)

func (*DataBalancerConfig) MarshalTo 

func (m *DataBalancerConfig) MarshalTo(dAtA []byte) (int, error)

func (*DataBalancerConfig) ProtoMessage 

func (*DataBalancerConfig) ProtoMessage()

func (*DataBalancerConfig) Reset 

func (m *DataBalancerConfig) Reset()

func (*DataBalancerConfig) Size 

func (m *DataBalancerConfig) Size() (n int)

func (*DataBalancerConfig) String 

func (m *DataBalancerConfig) String() string

func (*DataBalancerConfig) Unmarshal 

func (m *DataBalancerConfig) Unmarshal(dAtA []byte) error

func (*DataBalancerConfig) XXX_DiscardUnknown 

func (m *DataBalancerConfig) XXX_DiscardUnknown()

func (*DataBalancerConfig) XXX_Marshal 

func (m *DataBalancerConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataBalancerConfig) XXX_Merge 

func (m *DataBalancerConfig) XXX_Merge(src proto.Message)

func (*DataBalancerConfig) XXX_Size 

func (m *DataBalancerConfig) XXX_Size() int

func (*DataBalancerConfig) XXX_Unmarshal 

func (m *DataBalancerConfig) XXX_Unmarshal(b []byte) error

type DeleteSchemaRegistryClusterReply 

type DeleteSchemaRegistryClusterReply struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSchemaRegistryClusterReply) Descriptor 

func (*DeleteSchemaRegistryClusterReply) Descriptor() ([]byte, []int)

func (*DeleteSchemaRegistryClusterReply) GetError 

func (m *DeleteSchemaRegistryClusterReply) GetError() *Error

func (*DeleteSchemaRegistryClusterReply) Marshal 

func (m *DeleteSchemaRegistryClusterReply) Marshal() (dAtA []byte, err error)

func (*DeleteSchemaRegistryClusterReply) MarshalTo 

func (m *DeleteSchemaRegistryClusterReply) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSchemaRegistryClusterReply) ProtoMessage 

func (*DeleteSchemaRegistryClusterReply) ProtoMessage()

func (*DeleteSchemaRegistryClusterReply) Reset 

func (m *DeleteSchemaRegistryClusterReply) Reset()

func (*DeleteSchemaRegistryClusterReply) Size 

func (m *DeleteSchemaRegistryClusterReply) Size() (n int)

func (*DeleteSchemaRegistryClusterReply) String 

func (m *DeleteSchemaRegistryClusterReply) String() string

func (*DeleteSchemaRegistryClusterReply) Unmarshal 

func (m *DeleteSchemaRegistryClusterReply) Unmarshal(dAtA []byte) error

func (*DeleteSchemaRegistryClusterReply) XXX_DiscardUnknown 

func (m *DeleteSchemaRegistryClusterReply) XXX_DiscardUnknown()

func (*DeleteSchemaRegistryClusterReply) XXX_Marshal 

func (m *DeleteSchemaRegistryClusterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSchemaRegistryClusterReply) XXX_Merge 

func (m *DeleteSchemaRegistryClusterReply) XXX_Merge(src proto.Message)

func (*DeleteSchemaRegistryClusterReply) XXX_Size 

func (m *DeleteSchemaRegistryClusterReply) XXX_Size() int

func (*DeleteSchemaRegistryClusterReply) XXX_Unmarshal 

func (m *DeleteSchemaRegistryClusterReply) XXX_Unmarshal(b []byte) error

type DeleteSchemaValidationResourcesReply 

type DeleteSchemaValidationResourcesReply struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSchemaValidationResourcesReply) Descriptor 

func (*DeleteSchemaValidationResourcesReply) Descriptor() ([]byte, []int)

func (*DeleteSchemaValidationResourcesReply) GetError 

func (m *DeleteSchemaValidationResourcesReply) GetError() *Error

func (*DeleteSchemaValidationResourcesReply) Marshal 

func (m *DeleteSchemaValidationResourcesReply) Marshal() (dAtA []byte, err error)

func (*DeleteSchemaValidationResourcesReply) MarshalTo 

func (m *DeleteSchemaValidationResourcesReply) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSchemaValidationResourcesReply) ProtoMessage 

func (*DeleteSchemaValidationResourcesReply) ProtoMessage()

func (*DeleteSchemaValidationResourcesReply) Reset 

func (m *DeleteSchemaValidationResourcesReply) Reset()

func (*DeleteSchemaValidationResourcesReply) Size 

func (m *DeleteSchemaValidationResourcesReply) Size() (n int)

func (*DeleteSchemaValidationResourcesReply) String 

func (m *DeleteSchemaValidationResourcesReply) String() string

func (*DeleteSchemaValidationResourcesReply) Unmarshal 

func (m *DeleteSchemaValidationResourcesReply) Unmarshal(dAtA []byte) error

func (*DeleteSchemaValidationResourcesReply) XXX_DiscardUnknown 

func (m *DeleteSchemaValidationResourcesReply) XXX_DiscardUnknown()

func (*DeleteSchemaValidationResourcesReply) XXX_Marshal 

func (m *DeleteSchemaValidationResourcesReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSchemaValidationResourcesReply) XXX_Merge 

func (m *DeleteSchemaValidationResourcesReply) XXX_Merge(src proto.Message)

func (*DeleteSchemaValidationResourcesReply) XXX_Size 

func (m *DeleteSchemaValidationResourcesReply) XXX_Size() int

func (*DeleteSchemaValidationResourcesReply) XXX_Unmarshal 

func (m *DeleteSchemaValidationResourcesReply) XXX_Unmarshal(b []byte) error

type DeleteSchemaValidationResourcesRequest 

type DeleteSchemaValidationResourcesRequest struct {
	LogicalClusterId     string   `` /* 180-byte string literal not displayed */
	OrganizationId       int32    `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSchemaValidationResourcesRequest) Descriptor 

func (*DeleteSchemaValidationResourcesRequest) Descriptor() ([]byte, []int)

func (*DeleteSchemaValidationResourcesRequest) GetLogicalClusterId 

func (m *DeleteSchemaValidationResourcesRequest) GetLogicalClusterId() string

func (*DeleteSchemaValidationResourcesRequest) GetOrganizationId 

func (m *DeleteSchemaValidationResourcesRequest) GetOrganizationId() int32

func (*DeleteSchemaValidationResourcesRequest) Marshal 

func (m *DeleteSchemaValidationResourcesRequest) Marshal() (dAtA []byte, err error)

func (*DeleteSchemaValidationResourcesRequest) MarshalTo 

func (m *DeleteSchemaValidationResourcesRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSchemaValidationResourcesRequest) ProtoMessage 

func (*DeleteSchemaValidationResourcesRequest) ProtoMessage()

func (*DeleteSchemaValidationResourcesRequest) Reset 

func (m *DeleteSchemaValidationResourcesRequest) Reset()

func (*DeleteSchemaValidationResourcesRequest) Size 

func (m *DeleteSchemaValidationResourcesRequest) Size() (n int)

func (*DeleteSchemaValidationResourcesRequest) String 

func (m *DeleteSchemaValidationResourcesRequest) String() string

func (*DeleteSchemaValidationResourcesRequest) Unmarshal 

func (m *DeleteSchemaValidationResourcesRequest) Unmarshal(dAtA []byte) error

func (*DeleteSchemaValidationResourcesRequest) XXX_DiscardUnknown 

func (m *DeleteSchemaValidationResourcesRequest) XXX_DiscardUnknown()

func (*DeleteSchemaValidationResourcesRequest) XXX_Marshal 

func (m *DeleteSchemaValidationResourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSchemaValidationResourcesRequest) XXX_Merge 

func (m *DeleteSchemaValidationResourcesRequest) XXX_Merge(src proto.Message)

func (*DeleteSchemaValidationResourcesRequest) XXX_Size 

func (m *DeleteSchemaValidationResourcesRequest) XXX_Size() int

func (*DeleteSchemaValidationResourcesRequest) XXX_Unmarshal 

func (m *DeleteSchemaValidationResourcesRequest) XXX_Unmarshal(b []byte) error

type EnvironmentMetadata 

type EnvironmentMetadata interface {
	Get() ([]*CloudMetadata, error)
}

Environment metadata service allows getting information about available cloud regions data

type EnvironmentMetadataService 

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

EnvironmentMetadataServices provides methods for getting information about cloud regions.

func NewEnvironmentMetadataService 

func NewEnvironmentMetadataService(client *Client) *EnvironmentMetadataService

func (*EnvironmentMetadataService) Get 

func (s *EnvironmentMetadataService) Get() ([]*CloudMetadata, error)

type EnvironmentStatus 

type EnvironmentStatus struct {
	Info                 string   `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty" db:"info,omitempty" url:"info,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EnvironmentStatus) Descriptor 

func (*EnvironmentStatus) Descriptor() ([]byte, []int)

func (*EnvironmentStatus) GetError 

func (m *EnvironmentStatus) GetError() string

func (*EnvironmentStatus) GetInfo 

func (m *EnvironmentStatus) GetInfo() string

func (*EnvironmentStatus) Marshal 

func (m *EnvironmentStatus) Marshal() (dAtA []byte, err error)

func (*EnvironmentStatus) MarshalTo 

func (m *EnvironmentStatus) MarshalTo(dAtA []byte) (int, error)

func (*EnvironmentStatus) ProtoMessage 

func (*EnvironmentStatus) ProtoMessage()

func (*EnvironmentStatus) Reset 

func (m *EnvironmentStatus) Reset()

func (*EnvironmentStatus) Size 

func (m *EnvironmentStatus) Size() (n int)

func (*EnvironmentStatus) String 

func (m *EnvironmentStatus) String() string

func (*EnvironmentStatus) Unmarshal 

func (m *EnvironmentStatus) Unmarshal(dAtA []byte) error

func (*EnvironmentStatus) XXX_DiscardUnknown 

func (m *EnvironmentStatus) XXX_DiscardUnknown()

func (*EnvironmentStatus) XXX_Marshal 

func (m *EnvironmentStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnvironmentStatus) XXX_Merge 

func (m *EnvironmentStatus) XXX_Merge(src proto.Message)

func (*EnvironmentStatus) XXX_Size 

func (m *EnvironmentStatus) XXX_Size() int

func (*EnvironmentStatus) XXX_Unmarshal 

func (m *EnvironmentStatus) XXX_Unmarshal(b []byte) error

type Error 

type Error struct {
	// http status code
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty" db:"code,omitempty" url:"code,omitempty"`
	// a short, human-readable summary of the problem. It should not change from occurrence to occurrence of the problem
	Title string `protobuf:"bytes,9,opt,name=title,proto3" json:"title,omitempty" db:"title,omitempty" url:"title,omitempty"`
	// human-readable explanation specific to this occurrence of the problem
	Message      string            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" db:"message,omitempty" url:"message,omitempty"`
	NestedErrors map[string]string `` /* 244-byte string literal not displayed */
	Details      []string          `protobuf:"bytes,4,rep,name=details,proto3" json:"details,omitempty" db:"details,omitempty" url:"details,omitempty"`
	Stack        *Stack            `protobuf:"bytes,5,opt,name=stack,proto3,customtype=Stack" json:"stack,omitempty" db:"stack,omitempty" url:"stack,omitempty"`
	// an application-specific error code, expressed as a string value.
	ErrorCode string `` /* 141-byte string literal not displayed */
	// optional pointer to input request document
	Source *ErrorSource `protobuf:"bytes,7,opt,name=source,proto3" json:"source,omitempty" db:"source,omitempty" url:"source,omitempty"`
	// list of errors that are needed for public apis
	MultiErrors          []*Error `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor 

func (*Error) Descriptor() ([]byte, []int)

func (*Error) Error 

func (e *Error) Error() string

Error implements the error interface.

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetDetails 

func (m *Error) GetDetails() []string

func (*Error) GetErrorCode 

func (m *Error) GetErrorCode() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetMultiErrors 

func (m *Error) GetMultiErrors() []*Error

func (*Error) GetNestedErrors 

func (m *Error) GetNestedErrors() map[string]string

func (*Error) GetSource 

func (m *Error) GetSource() *ErrorSource

func (*Error) GetTitle 

func (m *Error) GetTitle() string

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

type ErrorSource 

type ErrorSource struct {
	// a JSON Pointer [RFC6901] to the associated entity in the request document [e.g. \"/data\" for a primary data object, or \"/data/attributes/title\" for a specific attribute].
	Pointer string `protobuf:"bytes,1,opt,name=pointer,proto3" json:"pointer,omitempty" db:"pointer,omitempty" url:"pointer,omitempty"`
	// a string indicating which query parameter caused the error.
	Parameter string `protobuf:"bytes,2,opt,name=parameter,proto3" json:"parameter,omitempty" db:"parameter,omitempty" url:"parameter,omitempty"`
	// a url indicating the location of the conflicting resource
	Location             string   `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty" db:"location,omitempty" url:"location,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ErrorSource) Descriptor 

func (*ErrorSource) Descriptor() ([]byte, []int)

func (*ErrorSource) GetLocation 

func (m *ErrorSource) GetLocation() string

func (*ErrorSource) GetParameter 

func (m *ErrorSource) GetParameter() string

func (*ErrorSource) GetPointer 

func (m *ErrorSource) GetPointer() string

func (*ErrorSource) Marshal 

func (m *ErrorSource) Marshal() (dAtA []byte, err error)

func (*ErrorSource) MarshalTo 

func (m *ErrorSource) MarshalTo(dAtA []byte) (int, error)

func (*ErrorSource) ProtoMessage 

func (*ErrorSource) ProtoMessage()

func (*ErrorSource) Reset 

func (m *ErrorSource) Reset()

func (*ErrorSource) Size 

func (m *ErrorSource) Size() (n int)

func (*ErrorSource) String 

func (m *ErrorSource) String() string

func (*ErrorSource) Unmarshal 

func (m *ErrorSource) Unmarshal(dAtA []byte) error

func (*ErrorSource) XXX_DiscardUnknown 

func (m *ErrorSource) XXX_DiscardUnknown()

func (*ErrorSource) XXX_Marshal 

func (m *ErrorSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorSource) XXX_Merge 

func (m *ErrorSource) XXX_Merge(src proto.Message)

func (*ErrorSource) XXX_Size 

func (m *ErrorSource) XXX_Size() int

func (*ErrorSource) XXX_Unmarshal 

func (m *ErrorSource) XXX_Unmarshal(b []byte) error

type Errorer 

type Errorer interface {
	GetError() *Error
}

type ExpiredTokenError 

type ExpiredTokenError struct{}

func (*ExpiredTokenError) Error 

func (e *ExpiredTokenError) Error() string

type ExternalIdentity 

type ExternalIdentity interface {
	CreateExternalIdentity(string, string) (string, error)
}

External Identity services allow managing external identities for Bring-Your-Own-Key in Confluent Cloud.

type ExternalIdentityService 

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

func NewExternalIdentityService 

func NewExternalIdentityService(client *Client) *ExternalIdentityService

func (*ExternalIdentityService) CreateExternalIdentity 

func (s *ExternalIdentityService) CreateExternalIdentity(cloud, accountID string) (string, error)

type FeatureFlagValue 

type FeatureFlagValue struct {
	// Types that are valid to be assigned to FlagValue:
	//	*FeatureFlagValue_IntVal
	//	*FeatureFlagValue_BoolVal
	//	*FeatureFlagValue_StringVal
	FlagValue            isFeatureFlagValue_FlagValue `protobuf_oneof:"flag_value"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Used by spec services to return feature flags to scheduler

func (*FeatureFlagValue) Descriptor 

func (*FeatureFlagValue) Descriptor() ([]byte, []int)

func (*FeatureFlagValue) GetBoolVal 

func (m *FeatureFlagValue) GetBoolVal() bool

func (*FeatureFlagValue) GetFlagValue 

func (m *FeatureFlagValue) GetFlagValue() isFeatureFlagValue_FlagValue

func (*FeatureFlagValue) GetIntVal 

func (m *FeatureFlagValue) GetIntVal() int64

func (*FeatureFlagValue) GetStringVal 

func (m *FeatureFlagValue) GetStringVal() string

func (*FeatureFlagValue) Marshal 

func (m *FeatureFlagValue) Marshal() (dAtA []byte, err error)

func (*FeatureFlagValue) MarshalTo 

func (m *FeatureFlagValue) MarshalTo(dAtA []byte) (int, error)

func (*FeatureFlagValue) ProtoMessage 

func (*FeatureFlagValue) ProtoMessage()

func (*FeatureFlagValue) Reset 

func (m *FeatureFlagValue) Reset()

func (*FeatureFlagValue) Size 

func (m *FeatureFlagValue) Size() (n int)

func (*FeatureFlagValue) String 

func (m *FeatureFlagValue) String() string

func (*FeatureFlagValue) Unmarshal 

func (m *FeatureFlagValue) Unmarshal(dAtA []byte) error

func (*FeatureFlagValue) XXX_DiscardUnknown 

func (m *FeatureFlagValue) XXX_DiscardUnknown()

func (*FeatureFlagValue) XXX_Marshal 

func (m *FeatureFlagValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureFlagValue) XXX_Merge 

func (m *FeatureFlagValue) XXX_Merge(src proto.Message)

func (*FeatureFlagValue) XXX_OneofFuncs 

func (*FeatureFlagValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*FeatureFlagValue) XXX_Size 

func (m *FeatureFlagValue) XXX_Size() int

func (*FeatureFlagValue) XXX_Unmarshal 

func (m *FeatureFlagValue) XXX_Unmarshal(b []byte) error

type FeatureFlagValue_BoolVal 

type FeatureFlagValue_BoolVal struct {
	BoolVal bool `protobuf:"varint,2,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

func (*FeatureFlagValue_BoolVal) MarshalTo 

func (m *FeatureFlagValue_BoolVal) MarshalTo(dAtA []byte) (int, error)

func (*FeatureFlagValue_BoolVal) Size 

func (m *FeatureFlagValue_BoolVal) Size() (n int)

type FeatureFlagValue_IntVal 

type FeatureFlagValue_IntVal struct {
	IntVal int64 `protobuf:"varint,1,opt,name=int_val,json=intVal,proto3,oneof"`
}

func (*FeatureFlagValue_IntVal) MarshalTo 

func (m *FeatureFlagValue_IntVal) MarshalTo(dAtA []byte) (int, error)

func (*FeatureFlagValue_IntVal) Size 

func (m *FeatureFlagValue_IntVal) Size() (n int)

type FeatureFlagValue_StringVal 

type FeatureFlagValue_StringVal struct {
	StringVal string `protobuf:"bytes,3,opt,name=string_val,json=stringVal,proto3,oneof"`
}

func (*FeatureFlagValue_StringVal) MarshalTo 

func (m *FeatureFlagValue_StringVal) MarshalTo(dAtA []byte) (int, error)

func (*FeatureFlagValue_StringVal) Size 

func (m *FeatureFlagValue_StringVal) Size() (n int)

type GetAccountReply 

type GetAccountReply struct {
	Account              *Account `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty" db:"account,omitempty" url:"account,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetAccountReply) Descriptor 

func (*GetAccountReply) Descriptor() ([]byte, []int)

func (*GetAccountReply) GetAccount 

func (m *GetAccountReply) GetAccount() *Account

func (*GetAccountReply) GetError 

func (m *GetAccountReply) GetError() *Error

func (*GetAccountReply) Marshal 

func (m *GetAccountReply) Marshal() (dAtA []byte, err error)

func (*GetAccountReply) MarshalTo 

func (m *GetAccountReply) MarshalTo(dAtA []byte) (int, error)

func (*GetAccountReply) ProtoMessage 

func (*GetAccountReply) ProtoMessage()

func (*GetAccountReply) Reset 

func (m *GetAccountReply) Reset()

func (*GetAccountReply) Size 

func (m *GetAccountReply) Size() (n int)

func (*GetAccountReply) String 

func (m *GetAccountReply) String() string

func (*GetAccountReply) Unmarshal 

func (m *GetAccountReply) Unmarshal(dAtA []byte) error

func (*GetAccountReply) XXX_DiscardUnknown 

func (m *GetAccountReply) XXX_DiscardUnknown()

func (*GetAccountReply) XXX_Marshal 

func (m *GetAccountReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAccountReply) XXX_Merge 

func (m *GetAccountReply) XXX_Merge(src proto.Message)

func (*GetAccountReply) XXX_Size 

func (m *GetAccountReply) XXX_Size() int

func (*GetAccountReply) XXX_Unmarshal 

func (m *GetAccountReply) XXX_Unmarshal(b []byte) error

type GetEnvironmentMetadataReply 

type GetEnvironmentMetadataReply struct {
	Error                   *Error                    `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Clouds                  []*CloudMetadata          `protobuf:"bytes,2,rep,name=clouds,proto3" json:"clouds,omitempty" db:"clouds,omitempty" url:"clouds,omitempty"`
	Status                  *EnvironmentStatus        `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty" db:"status,omitempty" url:"status,omitempty"`
	SchemaRegistryLocations []*SchemaRegistryLocation `` /* 215-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                  `json:"-"`
	XXX_unrecognized        []byte                    `json:"-"`
	XXX_sizecache           int32                     `json:"-"`
}

func (*GetEnvironmentMetadataReply) Descriptor 

func (*GetEnvironmentMetadataReply) Descriptor() ([]byte, []int)

func (*GetEnvironmentMetadataReply) GetClouds 

func (m *GetEnvironmentMetadataReply) GetClouds() []*CloudMetadata

func (*GetEnvironmentMetadataReply) GetError 

func (m *GetEnvironmentMetadataReply) GetError() *Error

func (*GetEnvironmentMetadataReply) GetSchemaRegistryLocations 

func (m *GetEnvironmentMetadataReply) GetSchemaRegistryLocations() []*SchemaRegistryLocation

func (*GetEnvironmentMetadataReply) GetStatus 

func (m *GetEnvironmentMetadataReply) GetStatus() *EnvironmentStatus

func (*GetEnvironmentMetadataReply) Marshal 

func (m *GetEnvironmentMetadataReply) Marshal() (dAtA []byte, err error)

func (*GetEnvironmentMetadataReply) MarshalTo 

func (m *GetEnvironmentMetadataReply) MarshalTo(dAtA []byte) (int, error)

func (*GetEnvironmentMetadataReply) ProtoMessage 

func (*GetEnvironmentMetadataReply) ProtoMessage()

func (*GetEnvironmentMetadataReply) Reset 

func (m *GetEnvironmentMetadataReply) Reset()

func (*GetEnvironmentMetadataReply) Size 

func (m *GetEnvironmentMetadataReply) Size() (n int)

func (*GetEnvironmentMetadataReply) String 

func (m *GetEnvironmentMetadataReply) String() string

func (*GetEnvironmentMetadataReply) Unmarshal 

func (m *GetEnvironmentMetadataReply) Unmarshal(dAtA []byte) error

func (*GetEnvironmentMetadataReply) XXX_DiscardUnknown 

func (m *GetEnvironmentMetadataReply) XXX_DiscardUnknown()

func (*GetEnvironmentMetadataReply) XXX_Marshal 

func (m *GetEnvironmentMetadataReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetEnvironmentMetadataReply) XXX_Merge 

func (m *GetEnvironmentMetadataReply) XXX_Merge(src proto.Message)

func (*GetEnvironmentMetadataReply) XXX_Size 

func (m *GetEnvironmentMetadataReply) XXX_Size() int

func (*GetEnvironmentMetadataReply) XXX_Unmarshal 

func (m *GetEnvironmentMetadataReply) XXX_Unmarshal(b []byte) error

type GetFreeTrialInfoReply 

type GetFreeTrialInfoReply struct {
	Error                *Error                  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	PromoCodeClaims      []*GrowthPromoCodeClaim `` /* 175-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetFreeTrialInfoReply) GetError 

func (m *GetFreeTrialInfoReply) GetError() *Error

func (*GetFreeTrialInfoReply) Marshal 

func (m *GetFreeTrialInfoReply) Marshal() (dAtA []byte, err error)

func (*GetFreeTrialInfoReply) MarshalTo 

func (m *GetFreeTrialInfoReply) MarshalTo(dAtA []byte) (int, error)

func (*GetFreeTrialInfoReply) ProtoMessage 

func (*GetFreeTrialInfoReply) ProtoMessage()

func (*GetFreeTrialInfoReply) Reset 

func (m *GetFreeTrialInfoReply) Reset()

func (*GetFreeTrialInfoReply) Size 

func (m *GetFreeTrialInfoReply) Size() (n int)

func (*GetFreeTrialInfoReply) String 

func (m *GetFreeTrialInfoReply) String() string

func (*GetFreeTrialInfoReply) Unmarshal 

func (m *GetFreeTrialInfoReply) Unmarshal(dAtA []byte) error

type GetFreeTrialInfoRequest 

type GetFreeTrialInfoRequest struct {
	RequestCarrier       map[string]string `` /* 254-byte string literal not displayed */
	OrgId                int32             `protobuf:"varint,2,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty" db:"org_id,omitempty" url:"org_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetFreeTrialInfoRequest) Marshal 

func (m *GetFreeTrialInfoRequest) Marshal() (dAtA []byte, err error)

func (*GetFreeTrialInfoRequest) MarshalTo 

func (m *GetFreeTrialInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetFreeTrialInfoRequest) ProtoMessage 

func (*GetFreeTrialInfoRequest) ProtoMessage()

func (*GetFreeTrialInfoRequest) Reset 

func (m *GetFreeTrialInfoRequest) Reset()

func (*GetFreeTrialInfoRequest) Size 

func (m *GetFreeTrialInfoRequest) Size() (n int)

func (*GetFreeTrialInfoRequest) String 

func (m *GetFreeTrialInfoRequest) String() string

func (*GetFreeTrialInfoRequest) Unmarshal 

func (m *GetFreeTrialInfoRequest) Unmarshal(dAtA []byte) error

type GetLoginRealmReply 

type GetLoginRealmReply struct {
	Realm                string   `protobuf:"bytes,1,opt,name=realm,proto3" json:"realm,omitempty" db:"realm,omitempty" url:"realm,omitempty"`
	IsSso                bool     `protobuf:"varint,2,opt,name=is_sso,json=isSso,proto3" json:"is_sso,omitempty" db:"is_sso,omitempty" url:"is_sso,omitempty"`
	Error                *Error   `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	MfaRequired          bool     `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLoginRealmReply) Descriptor 

func (*GetLoginRealmReply) Descriptor() ([]byte, []int)

func (*GetLoginRealmReply) GetError 

func (m *GetLoginRealmReply) GetError() *Error

func (*GetLoginRealmReply) GetIsSso 

func (m *GetLoginRealmReply) GetIsSso() bool

func (*GetLoginRealmReply) GetMfaRequired 

func (m *GetLoginRealmReply) GetMfaRequired() bool

func (*GetLoginRealmReply) GetRealm 

func (m *GetLoginRealmReply) GetRealm() string

func (*GetLoginRealmReply) Marshal 

func (m *GetLoginRealmReply) Marshal() (dAtA []byte, err error)

func (*GetLoginRealmReply) MarshalTo 

func (m *GetLoginRealmReply) MarshalTo(dAtA []byte) (int, error)

func (*GetLoginRealmReply) ProtoMessage 

func (*GetLoginRealmReply) ProtoMessage()

func (*GetLoginRealmReply) Reset 

func (m *GetLoginRealmReply) Reset()

func (*GetLoginRealmReply) Size 

func (m *GetLoginRealmReply) Size() (n int)

func (*GetLoginRealmReply) String 

func (m *GetLoginRealmReply) String() string

func (*GetLoginRealmReply) Unmarshal 

func (m *GetLoginRealmReply) Unmarshal(dAtA []byte) error

func (*GetLoginRealmReply) XXX_DiscardUnknown 

func (m *GetLoginRealmReply) XXX_DiscardUnknown()

func (*GetLoginRealmReply) XXX_Marshal 

func (m *GetLoginRealmReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLoginRealmReply) XXX_Merge 

func (m *GetLoginRealmReply) XXX_Merge(src proto.Message)

func (*GetLoginRealmReply) XXX_Size 

func (m *GetLoginRealmReply) XXX_Size() int

func (*GetLoginRealmReply) XXX_Unmarshal 

func (m *GetLoginRealmReply) XXX_Unmarshal(b []byte) error

type GetLoginRealmRequest 

type GetLoginRealmRequest struct {
	ClientId             string            `` /* 136-byte string literal not displayed */
	Email                string            `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty" db:"email,omitempty" url:"email,omitempty"`
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	OrgResourceId        string            `` /* 165-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetLoginRealmRequest) Descriptor 

func (*GetLoginRealmRequest) Descriptor() ([]byte, []int)

func (*GetLoginRealmRequest) GetClientId 

func (m *GetLoginRealmRequest) GetClientId() string

func (*GetLoginRealmRequest) GetEmail 

func (m *GetLoginRealmRequest) GetEmail() string

func (*GetLoginRealmRequest) GetOrgResourceId 

func (m *GetLoginRealmRequest) GetOrgResourceId() string

func (*GetLoginRealmRequest) GetRequestCarrier 

func (m *GetLoginRealmRequest) GetRequestCarrier() map[string]string

func (*GetLoginRealmRequest) Marshal 

func (m *GetLoginRealmRequest) Marshal() (dAtA []byte, err error)

func (*GetLoginRealmRequest) MarshalTo 

func (m *GetLoginRealmRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetLoginRealmRequest) ProtoMessage 

func (*GetLoginRealmRequest) ProtoMessage()

func (*GetLoginRealmRequest) Reset 

func (m *GetLoginRealmRequest) Reset()

func (*GetLoginRealmRequest) SetRequestCarrier 

func (t *GetLoginRealmRequest) SetRequestCarrier(request_carrier map[string]string)

func (*GetLoginRealmRequest) Size 

func (m *GetLoginRealmRequest) Size() (n int)

func (*GetLoginRealmRequest) String 

func (m *GetLoginRealmRequest) String() string

func (*GetLoginRealmRequest) Unmarshal 

func (m *GetLoginRealmRequest) Unmarshal(dAtA []byte) error

func (*GetLoginRealmRequest) XXX_DiscardUnknown 

func (m *GetLoginRealmRequest) XXX_DiscardUnknown()

func (*GetLoginRealmRequest) XXX_Marshal 

func (m *GetLoginRealmRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLoginRealmRequest) XXX_Merge 

func (m *GetLoginRealmRequest) XXX_Merge(src proto.Message)

func (*GetLoginRealmRequest) XXX_Size 

func (m *GetLoginRealmRequest) XXX_Size() int

func (*GetLoginRealmRequest) XXX_Unmarshal 

func (m *GetLoginRealmRequest) XXX_Unmarshal(b []byte) error

type GetMeReply 

type GetMeReply struct {
	Error                *Error        `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	User                 *User         `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	Organization         *Organization `` /* 134-byte string literal not displayed */
	Accounts             []*Account    `protobuf:"bytes,4,rep,name=accounts,proto3" json:"accounts,omitempty" db:"accounts,omitempty" url:"accounts,omitempty"`
	Account              *Account      `protobuf:"bytes,5,opt,name=account,proto3" json:"account,omitempty" db:"account,omitempty" url:"account,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetMeReply) Descriptor 

func (*GetMeReply) Descriptor() ([]byte, []int)

func (*GetMeReply) GetAccount 

func (m *GetMeReply) GetAccount() *Account

func (*GetMeReply) GetAccounts 

func (m *GetMeReply) GetAccounts() []*Account

func (*GetMeReply) GetError 

func (m *GetMeReply) GetError() *Error

func (*GetMeReply) GetOrganization 

func (m *GetMeReply) GetOrganization() *Organization

func (*GetMeReply) GetUser 

func (m *GetMeReply) GetUser() *User

func (*GetMeReply) Marshal 

func (m *GetMeReply) Marshal() (dAtA []byte, err error)

func (*GetMeReply) MarshalTo 

func (m *GetMeReply) MarshalTo(dAtA []byte) (int, error)

func (*GetMeReply) ProtoMessage 

func (*GetMeReply) ProtoMessage()

func (*GetMeReply) Reset 

func (m *GetMeReply) Reset()

func (*GetMeReply) Size 

func (m *GetMeReply) Size() (n int)

func (*GetMeReply) String 

func (m *GetMeReply) String() string

func (*GetMeReply) Unmarshal 

func (m *GetMeReply) Unmarshal(dAtA []byte) error

func (*GetMeReply) XXX_DiscardUnknown 

func (m *GetMeReply) XXX_DiscardUnknown()

func (*GetMeReply) XXX_Marshal 

func (m *GetMeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMeReply) XXX_Merge 

func (m *GetMeReply) XXX_Merge(src proto.Message)

func (*GetMeReply) XXX_Size 

func (m *GetMeReply) XXX_Size() int

func (*GetMeReply) XXX_Unmarshal 

func (m *GetMeReply) XXX_Unmarshal(b []byte) error

type GetMeRequest 

type GetMeRequest struct {
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetMeRequest) Descriptor 

func (*GetMeRequest) Descriptor() ([]byte, []int)

func (*GetMeRequest) GetRequestCarrier 

func (m *GetMeRequest) GetRequestCarrier() map[string]string

func (*GetMeRequest) Marshal 

func (m *GetMeRequest) Marshal() (dAtA []byte, err error)

func (*GetMeRequest) MarshalTo 

func (m *GetMeRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetMeRequest) ProtoMessage 

func (*GetMeRequest) ProtoMessage()

func (*GetMeRequest) Reset 

func (m *GetMeRequest) Reset()

func (*GetMeRequest) SetRequestCarrier 

func (t *GetMeRequest) SetRequestCarrier(request_carrier map[string]string)

func (*GetMeRequest) Size 

func (m *GetMeRequest) Size() (n int)

func (*GetMeRequest) String 

func (m *GetMeRequest) String() string

func (*GetMeRequest) Unmarshal 

func (m *GetMeRequest) Unmarshal(dAtA []byte) error

func (*GetMeRequest) XXX_DiscardUnknown 

func (m *GetMeRequest) XXX_DiscardUnknown()

func (*GetMeRequest) XXX_Marshal 

func (m *GetMeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMeRequest) XXX_Merge 

func (m *GetMeRequest) XXX_Merge(src proto.Message)

func (*GetMeRequest) XXX_Size 

func (m *GetMeRequest) XXX_Size() int

func (*GetMeRequest) XXX_Unmarshal 

func (m *GetMeRequest) XXX_Unmarshal(b []byte) error

type GetPaymentInfoReply 

type GetPaymentInfoReply struct {
	Card                 *Card         `protobuf:"bytes,1,opt,name=card,proto3" json:"card,omitempty" db:"card,omitempty" url:"card,omitempty"`
	Organization         *Organization `` /* 134-byte string literal not displayed */
	Error                *Error        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	TaxAddress           *TaxAddress   `` /* 146-byte string literal not displayed */
	TaxIds               []*TaxId      `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetPaymentInfoReply) Descriptor 

func (*GetPaymentInfoReply) Descriptor() ([]byte, []int)

func (*GetPaymentInfoReply) GetCard 

func (m *GetPaymentInfoReply) GetCard() *Card

func (*GetPaymentInfoReply) GetError 

func (m *GetPaymentInfoReply) GetError() *Error

func (*GetPaymentInfoReply) GetOrganization 

func (m *GetPaymentInfoReply) GetOrganization() *Organization

func (*GetPaymentInfoReply) GetTaxAddress 

func (m *GetPaymentInfoReply) GetTaxAddress() *TaxAddress

func (*GetPaymentInfoReply) GetTaxIds 

func (m *GetPaymentInfoReply) GetTaxIds() []*TaxId

func (*GetPaymentInfoReply) Marshal 

func (m *GetPaymentInfoReply) Marshal() (dAtA []byte, err error)

func (*GetPaymentInfoReply) MarshalTo 

func (m *GetPaymentInfoReply) MarshalTo(dAtA []byte) (int, error)

func (*GetPaymentInfoReply) ProtoMessage 

func (*GetPaymentInfoReply) ProtoMessage()

func (*GetPaymentInfoReply) Reset 

func (m *GetPaymentInfoReply) Reset()

func (*GetPaymentInfoReply) Size 

func (m *GetPaymentInfoReply) Size() (n int)

func (*GetPaymentInfoReply) String 

func (m *GetPaymentInfoReply) String() string

func (*GetPaymentInfoReply) Unmarshal 

func (m *GetPaymentInfoReply) Unmarshal(dAtA []byte) error

func (*GetPaymentInfoReply) XXX_DiscardUnknown 

func (m *GetPaymentInfoReply) XXX_DiscardUnknown()

func (*GetPaymentInfoReply) XXX_Marshal 

func (m *GetPaymentInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPaymentInfoReply) XXX_Merge 

func (m *GetPaymentInfoReply) XXX_Merge(src proto.Message)

func (*GetPaymentInfoReply) XXX_Size 

func (m *GetPaymentInfoReply) XXX_Size() int

func (*GetPaymentInfoReply) XXX_Unmarshal 

func (m *GetPaymentInfoReply) XXX_Unmarshal(b []byte) error

type GetPriceTableReply 

type GetPriceTableReply struct {
	PriceTable           *PriceTable `` /* 146-byte string literal not displayed */
	Error                *Error      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetPriceTableReply) Descriptor 

func (*GetPriceTableReply) Descriptor() ([]byte, []int)

func (*GetPriceTableReply) GetError 

func (m *GetPriceTableReply) GetError() *Error

func (*GetPriceTableReply) GetPriceTable 

func (m *GetPriceTableReply) GetPriceTable() *PriceTable

func (*GetPriceTableReply) Marshal 

func (m *GetPriceTableReply) Marshal() (dAtA []byte, err error)

func (*GetPriceTableReply) MarshalTo 

func (m *GetPriceTableReply) MarshalTo(dAtA []byte) (int, error)

func (*GetPriceTableReply) ProtoMessage 

func (*GetPriceTableReply) ProtoMessage()

func (*GetPriceTableReply) Reset 

func (m *GetPriceTableReply) Reset()

func (*GetPriceTableReply) Size 

func (m *GetPriceTableReply) Size() (n int)

func (*GetPriceTableReply) String 

func (m *GetPriceTableReply) String() string

func (*GetPriceTableReply) Unmarshal 

func (m *GetPriceTableReply) Unmarshal(dAtA []byte) error

func (*GetPriceTableReply) XXX_DiscardUnknown 

func (m *GetPriceTableReply) XXX_DiscardUnknown()

func (*GetPriceTableReply) XXX_Marshal 

func (m *GetPriceTableReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPriceTableReply) XXX_Merge 

func (m *GetPriceTableReply) XXX_Merge(src proto.Message)

func (*GetPriceTableReply) XXX_Size 

func (m *GetPriceTableReply) XXX_Size() int

func (*GetPriceTableReply) XXX_Unmarshal 

func (m *GetPriceTableReply) XXX_Unmarshal(b []byte) error

type GetPromoCodeClaimsReply 

type GetPromoCodeClaimsReply struct {
	Claims               []*PromoCodeClaim `protobuf:"bytes,1,rep,name=claims,proto3" json:"claims,omitempty" db:"claims,omitempty" url:"claims,omitempty"`
	Error                *Error            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetPromoCodeClaimsReply) Descriptor 

func (*GetPromoCodeClaimsReply) Descriptor() ([]byte, []int)

func (*GetPromoCodeClaimsReply) GetClaims 

func (m *GetPromoCodeClaimsReply) GetClaims() []*PromoCodeClaim

func (*GetPromoCodeClaimsReply) GetError 

func (m *GetPromoCodeClaimsReply) GetError() *Error

func (*GetPromoCodeClaimsReply) Marshal 

func (m *GetPromoCodeClaimsReply) Marshal() (dAtA []byte, err error)

func (*GetPromoCodeClaimsReply) MarshalTo 

func (m *GetPromoCodeClaimsReply) MarshalTo(dAtA []byte) (int, error)

func (*GetPromoCodeClaimsReply) ProtoMessage 

func (*GetPromoCodeClaimsReply) ProtoMessage()

func (*GetPromoCodeClaimsReply) Reset 

func (m *GetPromoCodeClaimsReply) Reset()

func (*GetPromoCodeClaimsReply) Size 

func (m *GetPromoCodeClaimsReply) Size() (n int)

func (*GetPromoCodeClaimsReply) String 

func (m *GetPromoCodeClaimsReply) String() string

func (*GetPromoCodeClaimsReply) Unmarshal 

func (m *GetPromoCodeClaimsReply) Unmarshal(dAtA []byte) error

func (*GetPromoCodeClaimsReply) XXX_DiscardUnknown 

func (m *GetPromoCodeClaimsReply) XXX_DiscardUnknown()

func (*GetPromoCodeClaimsReply) XXX_Marshal 

func (m *GetPromoCodeClaimsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPromoCodeClaimsReply) XXX_Merge 

func (m *GetPromoCodeClaimsReply) XXX_Merge(src proto.Message)

func (*GetPromoCodeClaimsReply) XXX_Size 

func (m *GetPromoCodeClaimsReply) XXX_Size() int

func (*GetPromoCodeClaimsReply) XXX_Unmarshal 

func (m *GetPromoCodeClaimsReply) XXX_Unmarshal(b []byte) error

type GetPromoCodeClaimsRequest 

type GetPromoCodeClaimsRequest struct {
	OrgId                int32             `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty" db:"org_id,omitempty" url:"org_id,omitempty"`
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	ExcludeExpired       bool              `` /* 167-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetPromoCodeClaimsRequest) Descriptor 

func (*GetPromoCodeClaimsRequest) Descriptor() ([]byte, []int)

func (*GetPromoCodeClaimsRequest) GetExcludeExpired 

func (m *GetPromoCodeClaimsRequest) GetExcludeExpired() bool

func (*GetPromoCodeClaimsRequest) GetOrgId 

func (m *GetPromoCodeClaimsRequest) GetOrgId() int32

func (*GetPromoCodeClaimsRequest) GetRequestCarrier 

func (m *GetPromoCodeClaimsRequest) GetRequestCarrier() map[string]string

func (*GetPromoCodeClaimsRequest) Marshal 

func (m *GetPromoCodeClaimsRequest) Marshal() (dAtA []byte, err error)

func (*GetPromoCodeClaimsRequest) MarshalTo 

func (m *GetPromoCodeClaimsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetPromoCodeClaimsRequest) ProtoMessage 

func (*GetPromoCodeClaimsRequest) ProtoMessage()

func (*GetPromoCodeClaimsRequest) Reset 

func (m *GetPromoCodeClaimsRequest) Reset()

func (*GetPromoCodeClaimsRequest) SetRequestCarrier 

func (t *GetPromoCodeClaimsRequest) SetRequestCarrier(request_carrier map[string]string)

func (*GetPromoCodeClaimsRequest) Size 

func (m *GetPromoCodeClaimsRequest) Size() (n int)

func (*GetPromoCodeClaimsRequest) String 

func (m *GetPromoCodeClaimsRequest) String() string

func (*GetPromoCodeClaimsRequest) Unmarshal 

func (m *GetPromoCodeClaimsRequest) Unmarshal(dAtA []byte) error

func (*GetPromoCodeClaimsRequest) XXX_DiscardUnknown 

func (m *GetPromoCodeClaimsRequest) XXX_DiscardUnknown()

func (*GetPromoCodeClaimsRequest) XXX_Marshal 

func (m *GetPromoCodeClaimsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPromoCodeClaimsRequest) XXX_Merge 

func (m *GetPromoCodeClaimsRequest) XXX_Merge(src proto.Message)

func (*GetPromoCodeClaimsRequest) XXX_Size 

func (m *GetPromoCodeClaimsRequest) XXX_Size() int

func (*GetPromoCodeClaimsRequest) XXX_Unmarshal 

func (m *GetPromoCodeClaimsRequest) XXX_Unmarshal(b []byte) error

type GetSchemaRegistryClusterReply 

type GetSchemaRegistryClusterReply struct {
	Error                *Error                 `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Cluster              *SchemaRegistryCluster `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetSchemaRegistryClusterReply) Descriptor 

func (*GetSchemaRegistryClusterReply) Descriptor() ([]byte, []int)

func (*GetSchemaRegistryClusterReply) GetCluster 

func (m *GetSchemaRegistryClusterReply) GetCluster() *SchemaRegistryCluster

func (*GetSchemaRegistryClusterReply) GetError 

func (m *GetSchemaRegistryClusterReply) GetError() *Error

func (*GetSchemaRegistryClusterReply) Marshal 

func (m *GetSchemaRegistryClusterReply) Marshal() (dAtA []byte, err error)

func (*GetSchemaRegistryClusterReply) MarshalTo 

func (m *GetSchemaRegistryClusterReply) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemaRegistryClusterReply) ProtoMessage 

func (*GetSchemaRegistryClusterReply) ProtoMessage()

func (*GetSchemaRegistryClusterReply) Reset 

func (m *GetSchemaRegistryClusterReply) Reset()

func (*GetSchemaRegistryClusterReply) Size 

func (m *GetSchemaRegistryClusterReply) Size() (n int)

func (*GetSchemaRegistryClusterReply) String 

func (m *GetSchemaRegistryClusterReply) String() string

func (*GetSchemaRegistryClusterReply) Unmarshal 

func (m *GetSchemaRegistryClusterReply) Unmarshal(dAtA []byte) error

func (*GetSchemaRegistryClusterReply) XXX_DiscardUnknown 

func (m *GetSchemaRegistryClusterReply) XXX_DiscardUnknown()

func (*GetSchemaRegistryClusterReply) XXX_Marshal 

func (m *GetSchemaRegistryClusterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSchemaRegistryClusterReply) XXX_Merge 

func (m *GetSchemaRegistryClusterReply) XXX_Merge(src proto.Message)

func (*GetSchemaRegistryClusterReply) XXX_Size 

func (m *GetSchemaRegistryClusterReply) XXX_Size() int

func (*GetSchemaRegistryClusterReply) XXX_Unmarshal 

func (m *GetSchemaRegistryClusterReply) XXX_Unmarshal(b []byte) error

type GetSchemaRegistryClustersReply 

type GetSchemaRegistryClustersReply struct {
	Error                *Error                   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Clusters             []*SchemaRegistryCluster `protobuf:"bytes,2,rep,name=clusters,proto3" json:"clusters,omitempty" db:"clusters,omitempty" url:"clusters,omitempty"`
	NextPageToken        string                   `` /* 165-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*GetSchemaRegistryClustersReply) Descriptor 

func (*GetSchemaRegistryClustersReply) Descriptor() ([]byte, []int)

func (*GetSchemaRegistryClustersReply) GetClusters 

func (m *GetSchemaRegistryClustersReply) GetClusters() []*SchemaRegistryCluster

func (*GetSchemaRegistryClustersReply) GetError 

func (m *GetSchemaRegistryClustersReply) GetError() *Error

func (*GetSchemaRegistryClustersReply) GetNextPageToken 

func (m *GetSchemaRegistryClustersReply) GetNextPageToken() string

func (*GetSchemaRegistryClustersReply) Marshal 

func (m *GetSchemaRegistryClustersReply) Marshal() (dAtA []byte, err error)

func (*GetSchemaRegistryClustersReply) MarshalTo 

func (m *GetSchemaRegistryClustersReply) MarshalTo(dAtA []byte) (int, error)

func (*GetSchemaRegistryClustersReply) ProtoMessage 

func (*GetSchemaRegistryClustersReply) ProtoMessage()

func (*GetSchemaRegistryClustersReply) Reset 

func (m *GetSchemaRegistryClustersReply) Reset()

func (*GetSchemaRegistryClustersReply) Size 

func (m *GetSchemaRegistryClustersReply) Size() (n int)

func (*GetSchemaRegistryClustersReply) String 

func (m *GetSchemaRegistryClustersReply) String() string

func (*GetSchemaRegistryClustersReply) Unmarshal 

func (m *GetSchemaRegistryClustersReply) Unmarshal(dAtA []byte) error

func (*GetSchemaRegistryClustersReply) XXX_DiscardUnknown 

func (m *GetSchemaRegistryClustersReply) XXX_DiscardUnknown()

func (*GetSchemaRegistryClustersReply) XXX_Marshal 

func (m *GetSchemaRegistryClustersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSchemaRegistryClustersReply) XXX_Merge 

func (m *GetSchemaRegistryClustersReply) XXX_Merge(src proto.Message)

func (*GetSchemaRegistryClustersReply) XXX_Size 

func (m *GetSchemaRegistryClustersReply) XXX_Size() int

func (*GetSchemaRegistryClustersReply) XXX_Unmarshal 

func (m *GetSchemaRegistryClustersReply) XXX_Unmarshal(b []byte) error

type GetServiceAccountReply 

type GetServiceAccountReply struct {
	User                 *User    `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetServiceAccountReply contains the requested service account user

func (*GetServiceAccountReply) Descriptor 

func (*GetServiceAccountReply) Descriptor() ([]byte, []int)

func (*GetServiceAccountReply) GetError 

func (m *GetServiceAccountReply) GetError() *Error

func (*GetServiceAccountReply) GetUser 

func (m *GetServiceAccountReply) GetUser() *User

func (*GetServiceAccountReply) Marshal 

func (m *GetServiceAccountReply) Marshal() (dAtA []byte, err error)

func (*GetServiceAccountReply) MarshalTo 

func (m *GetServiceAccountReply) MarshalTo(dAtA []byte) (int, error)

func (*GetServiceAccountReply) ProtoMessage 

func (*GetServiceAccountReply) ProtoMessage()

func (*GetServiceAccountReply) Reset 

func (m *GetServiceAccountReply) Reset()

func (*GetServiceAccountReply) Size 

func (m *GetServiceAccountReply) Size() (n int)

func (*GetServiceAccountReply) String 

func (m *GetServiceAccountReply) String() string

func (*GetServiceAccountReply) Unmarshal 

func (m *GetServiceAccountReply) Unmarshal(dAtA []byte) error

func (*GetServiceAccountReply) XXX_DiscardUnknown 

func (m *GetServiceAccountReply) XXX_DiscardUnknown()

func (*GetServiceAccountReply) XXX_Marshal 

func (m *GetServiceAccountReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServiceAccountReply) XXX_Merge 

func (m *GetServiceAccountReply) XXX_Merge(src proto.Message)

func (*GetServiceAccountReply) XXX_Size 

func (m *GetServiceAccountReply) XXX_Size() int

func (*GetServiceAccountReply) XXX_Unmarshal 

func (m *GetServiceAccountReply) XXX_Unmarshal(b []byte) error

type GetServiceAccountRequest 

type GetServiceAccountRequest struct {
	User                 *User             `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	IncludeDeactivated   bool              `` /* 187-byte string literal not displayed */
	Organization         *Organization     `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Following fields are required to get the service account id of the service account.

func (*GetServiceAccountRequest) Descriptor 

func (*GetServiceAccountRequest) Descriptor() ([]byte, []int)

func (*GetServiceAccountRequest) GetIncludeDeactivated 

func (m *GetServiceAccountRequest) GetIncludeDeactivated() bool

func (*GetServiceAccountRequest) GetOrganization 

func (m *GetServiceAccountRequest) GetOrganization() *Organization

func (*GetServiceAccountRequest) GetRequestCarrier 

func (m *GetServiceAccountRequest) GetRequestCarrier() map[string]string

func (*GetServiceAccountRequest) GetUser 

func (m *GetServiceAccountRequest) GetUser() *User

func (*GetServiceAccountRequest) Marshal 

func (m *GetServiceAccountRequest) Marshal() (dAtA []byte, err error)

func (*GetServiceAccountRequest) MarshalTo 

func (m *GetServiceAccountRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetServiceAccountRequest) ProtoMessage 

func (*GetServiceAccountRequest) ProtoMessage()

func (*GetServiceAccountRequest) Reset 

func (m *GetServiceAccountRequest) Reset()

func (*GetServiceAccountRequest) SetRequestCarrier 

func (t *GetServiceAccountRequest) SetRequestCarrier(request_carrier map[string]string)

func (*GetServiceAccountRequest) Size 

func (m *GetServiceAccountRequest) Size() (n int)

func (*GetServiceAccountRequest) String 

func (m *GetServiceAccountRequest) String() string

func (*GetServiceAccountRequest) Unmarshal 

func (m *GetServiceAccountRequest) Unmarshal(dAtA []byte) error

func (*GetServiceAccountRequest) XXX_DiscardUnknown 

func (m *GetServiceAccountRequest) XXX_DiscardUnknown()

func (*GetServiceAccountRequest) XXX_Marshal 

func (m *GetServiceAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServiceAccountRequest) XXX_Merge 

func (m *GetServiceAccountRequest) XXX_Merge(src proto.Message)

func (*GetServiceAccountRequest) XXX_Size 

func (m *GetServiceAccountRequest) XXX_Size() int

func (*GetServiceAccountRequest) XXX_Unmarshal 

func (m *GetServiceAccountRequest) XXX_Unmarshal(b []byte) error

type GetServiceAccountsReply 

type GetServiceAccountsReply struct {
	Users                []*User   `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty" db:"users,omitempty" url:"users,omitempty"`
	Error                *Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	PageInfo             *PageInfo `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

GetServiceAccountsReply contains the requests service account user

func (*GetServiceAccountsReply) Descriptor 

func (*GetServiceAccountsReply) Descriptor() ([]byte, []int)

func (*GetServiceAccountsReply) GetError 

func (m *GetServiceAccountsReply) GetError() *Error

func (*GetServiceAccountsReply) GetPageInfo 

func (m *GetServiceAccountsReply) GetPageInfo() *PageInfo

func (*GetServiceAccountsReply) GetUsers 

func (m *GetServiceAccountsReply) GetUsers() []*User

func (*GetServiceAccountsReply) Marshal 

func (m *GetServiceAccountsReply) Marshal() (dAtA []byte, err error)

func (*GetServiceAccountsReply) MarshalTo 

func (m *GetServiceAccountsReply) MarshalTo(dAtA []byte) (int, error)

func (*GetServiceAccountsReply) ProtoMessage 

func (*GetServiceAccountsReply) ProtoMessage()

func (*GetServiceAccountsReply) Reset 

func (m *GetServiceAccountsReply) Reset()

func (*GetServiceAccountsReply) Size 

func (m *GetServiceAccountsReply) Size() (n int)

func (*GetServiceAccountsReply) String 

func (m *GetServiceAccountsReply) String() string

func (*GetServiceAccountsReply) Unmarshal 

func (m *GetServiceAccountsReply) Unmarshal(dAtA []byte) error

func (*GetServiceAccountsReply) XXX_DiscardUnknown 

func (m *GetServiceAccountsReply) XXX_DiscardUnknown()

func (*GetServiceAccountsReply) XXX_Marshal 

func (m *GetServiceAccountsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServiceAccountsReply) XXX_Merge 

func (m *GetServiceAccountsReply) XXX_Merge(src proto.Message)

func (*GetServiceAccountsReply) XXX_Size 

func (m *GetServiceAccountsReply) XXX_Size() int

func (*GetServiceAccountsReply) XXX_Unmarshal 

func (m *GetServiceAccountsReply) XXX_Unmarshal(b []byte) error

type GetServiceAccountsRequest 

type GetServiceAccountsRequest struct {
	User                 *User             `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	PageInfo             *PageInfo         `` /* 136-byte string literal not displayed */
	Organization         *Organization     `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Following fields are required to get the service account id, organization_id of the super user making the request.

func (*GetServiceAccountsRequest) Descriptor 

func (*GetServiceAccountsRequest) Descriptor() ([]byte, []int)

func (*GetServiceAccountsRequest) GetOrganization 

func (m *GetServiceAccountsRequest) GetOrganization() *Organization

func (*GetServiceAccountsRequest) GetPageInfo 

func (m *GetServiceAccountsRequest) GetPageInfo() *PageInfo

func (*GetServiceAccountsRequest) GetRequestCarrier 

func (m *GetServiceAccountsRequest) GetRequestCarrier() map[string]string

func (*GetServiceAccountsRequest) GetUser 

func (m *GetServiceAccountsRequest) GetUser() *User

func (*GetServiceAccountsRequest) Marshal 

func (m *GetServiceAccountsRequest) Marshal() (dAtA []byte, err error)

func (*GetServiceAccountsRequest) MarshalTo 

func (m *GetServiceAccountsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetServiceAccountsRequest) ProtoMessage 

func (*GetServiceAccountsRequest) ProtoMessage()

func (*GetServiceAccountsRequest) Reset 

func (m *GetServiceAccountsRequest) Reset()

func (*GetServiceAccountsRequest) SetRequestCarrier 

func (t *GetServiceAccountsRequest) SetRequestCarrier(request_carrier map[string]string)

func (*GetServiceAccountsRequest) Size 

func (m *GetServiceAccountsRequest) Size() (n int)

func (*GetServiceAccountsRequest) String 

func (m *GetServiceAccountsRequest) String() string

func (*GetServiceAccountsRequest) Unmarshal 

func (m *GetServiceAccountsRequest) Unmarshal(dAtA []byte) error

func (*GetServiceAccountsRequest) XXX_DiscardUnknown 

func (m *GetServiceAccountsRequest) XXX_DiscardUnknown()

func (*GetServiceAccountsRequest) XXX_Marshal 

func (m *GetServiceAccountsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetServiceAccountsRequest) XXX_Merge 

func (m *GetServiceAccountsRequest) XXX_Merge(src proto.Message)

func (*GetServiceAccountsRequest) XXX_Size 

func (m *GetServiceAccountsRequest) XXX_Size() int

func (*GetServiceAccountsRequest) XXX_Unmarshal 

func (m *GetServiceAccountsRequest) XXX_Unmarshal(b []byte) error

type GetUsersReply 

type GetUsersReply struct {
	Users                []*User   `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty" db:"users,omitempty" url:"users,omitempty"`
	Error                *Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	PageInfo             *PageInfo `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetUsersReply) Descriptor 

func (*GetUsersReply) Descriptor() ([]byte, []int)

func (*GetUsersReply) GetError 

func (m *GetUsersReply) GetError() *Error

func (*GetUsersReply) GetPageInfo 

func (m *GetUsersReply) GetPageInfo() *PageInfo

func (*GetUsersReply) GetUsers 

func (m *GetUsersReply) GetUsers() []*User

func (*GetUsersReply) Marshal 

func (m *GetUsersReply) Marshal() (dAtA []byte, err error)

func (*GetUsersReply) MarshalTo 

func (m *GetUsersReply) MarshalTo(dAtA []byte) (int, error)

func (*GetUsersReply) ProtoMessage 

func (*GetUsersReply) ProtoMessage()

func (*GetUsersReply) Reset 

func (m *GetUsersReply) Reset()

func (*GetUsersReply) Size 

func (m *GetUsersReply) Size() (n int)

func (*GetUsersReply) String 

func (m *GetUsersReply) String() string

func (*GetUsersReply) Unmarshal 

func (m *GetUsersReply) Unmarshal(dAtA []byte) error

func (*GetUsersReply) XXX_DiscardUnknown 

func (m *GetUsersReply) XXX_DiscardUnknown()

func (*GetUsersReply) XXX_Marshal 

func (m *GetUsersReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetUsersReply) XXX_Merge 

func (m *GetUsersReply) XXX_Merge(src proto.Message)

func (*GetUsersReply) XXX_Size 

func (m *GetUsersReply) XXX_Size() int

func (*GetUsersReply) XXX_Unmarshal 

func (m *GetUsersReply) XXX_Unmarshal(b []byte) error

type GlobalSchemaRegistryLocation 

type GlobalSchemaRegistryLocation int32
const (
	GlobalSchemaRegistryLocation_NONE GlobalSchemaRegistryLocation = 0
	GlobalSchemaRegistryLocation_US   GlobalSchemaRegistryLocation = 1
	GlobalSchemaRegistryLocation_EU   GlobalSchemaRegistryLocation = 2
	GlobalSchemaRegistryLocation_APAC GlobalSchemaRegistryLocation = 3
)

func (GlobalSchemaRegistryLocation) EnumDescriptor 

func (GlobalSchemaRegistryLocation) EnumDescriptor() ([]byte, []int)

func (GlobalSchemaRegistryLocation) String 

func (x GlobalSchemaRegistryLocation) String() string

type Growth 

type Growth interface {
	GetFreeTrialInfo(int32) ([]*GrowthPromoCodeClaim, error)
}

type GrowthPromoCodeClaim 

type GrowthPromoCodeClaim struct {
	Amount               int64            `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty" db:"amount,omitempty" url:"amount,omitempty"`
	Balance              int64            `protobuf:"varint,2,opt,name=balance,proto3" json:"balance,omitempty" db:"balance,omitempty" url:"balance,omitempty"`
	ClaimDate            *types.Timestamp `` /* 141-byte string literal not displayed */
	CreditExpirationDate *types.Timestamp `` /* 200-byte string literal not displayed */
	IsFreeTrialPromoCode bool             `` /* 209-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GrowthPromoCodeClaim) GetAmount 

func (m *GrowthPromoCodeClaim) GetAmount() int64

func (*GrowthPromoCodeClaim) GetBalance 

func (m *GrowthPromoCodeClaim) GetBalance() int64

func (*GrowthPromoCodeClaim) GetClaimDate 

func (m *GrowthPromoCodeClaim) GetClaimDate() *types.Timestamp

func (*GrowthPromoCodeClaim) GetCreditExpirationDate 

func (m *GrowthPromoCodeClaim) GetCreditExpirationDate() *types.Timestamp

func (*GrowthPromoCodeClaim) GetIsFreeTrialPromoCode 

func (m *GrowthPromoCodeClaim) GetIsFreeTrialPromoCode() bool

func (*GrowthPromoCodeClaim) Marshal 

func (m *GrowthPromoCodeClaim) Marshal() (dAtA []byte, err error)

func (*GrowthPromoCodeClaim) MarshalTo 

func (m *GrowthPromoCodeClaim) MarshalTo(dAtA []byte) (int, error)

func (*GrowthPromoCodeClaim) ProtoMessage 

func (*GrowthPromoCodeClaim) ProtoMessage()

func (*GrowthPromoCodeClaim) Reset 

func (m *GrowthPromoCodeClaim) Reset()

func (*GrowthPromoCodeClaim) Size 

func (m *GrowthPromoCodeClaim) Size() (n int)

func (*GrowthPromoCodeClaim) String 

func (m *GrowthPromoCodeClaim) String() string

func (*GrowthPromoCodeClaim) Unmarshal 

func (m *GrowthPromoCodeClaim) Unmarshal(dAtA []byte) error

type GrowthService 

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

func NewGrowthService 

func NewGrowthService(client *Client) *GrowthService

func (*GrowthService) GetFreeTrialInfo 

func (o *GrowthService) GetFreeTrialInfo(orgId int32) ([]*GrowthPromoCodeClaim, error)

type InvalidLoginError 

type InvalidLoginError struct{}

func (*InvalidLoginError) Error 

func (e *InvalidLoginError) Error() string

type InvalidTokenError 

type InvalidTokenError struct {
	Message string
}

func (*InvalidTokenError) Error 

func (e *InvalidTokenError) Error() string

type JSONPBBodyProvider 

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

JSONPBBodyProvider serializes request bodies as protobuf JSON messages by implementing sling.BodyProvider.

This encodes a JSON tagged struct value as a Body for requests. See https://godoc.org/github.com/golang/protobuf/jsonpb#Marshaler for details.

func NewJSONPBBodyProvider 

func NewJSONPBBodyProvider(body proto.Message) *JSONPBBodyProvider

JSONPBBodyProvider returns a new JSONPBBodyProvider

func (*JSONPBBodyProvider) Body 

func (p *JSONPBBodyProvider) Body() (io.Reader, error)

func (*JSONPBBodyProvider) ContentType 

func (p *JSONPBBodyProvider) ContentType() string

type JSONPBDecoder 

type JSONPBDecoder struct {
	jsonpb.Unmarshaler
}

JSONPBDecoder deserializes response bodies as protobuf JSON messages by implementing sling.Decoder.

func NewJSONPBDecoder 

func NewJSONPBDecoder() JSONPBDecoder

NewJSONPBDecoder returns a new JSONPBDecoder that's lenient for error responses.

func (JSONPBDecoder) Decode 

func (d JSONPBDecoder) Decode(resp *http.Response, v interface{}) error

Decode reads the next value from the reader and stores it in the value pointed to by v.

type JsonDecoder 

type JsonDecoder struct {
}

JsonDecoder decodes http response JSON into a JSON-tagged struct value.

This is copied from sling because they didn't export it and we need to "reset" the decoder to use basic json encoding sometimes (from a base sling instance)

func (JsonDecoder) Decode 

func (d JsonDecoder) Decode(resp *http.Response, v interface{}) error

Decode decodes the Response Body into the value pointed to by v. Caller must provide a non-nil v and close the resp.Body.

type KSQLHealthcheckExternalKeys 

type KSQLHealthcheckExternalKeys struct {
	DdApiKey             string   `` /* 151-byte string literal not displayed */
	KsqlKey              string   `` /* 131-byte string literal not displayed */
	KsqlSecret           string   `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KSQLHealthcheckExternalKeys) Descriptor 

func (*KSQLHealthcheckExternalKeys) Descriptor() ([]byte, []int)

func (*KSQLHealthcheckExternalKeys) GetDdApiKey 

func (m *KSQLHealthcheckExternalKeys) GetDdApiKey() string

func (*KSQLHealthcheckExternalKeys) GetKsqlKey 

func (m *KSQLHealthcheckExternalKeys) GetKsqlKey() string

func (*KSQLHealthcheckExternalKeys) GetKsqlSecret 

func (m *KSQLHealthcheckExternalKeys) GetKsqlSecret() string

func (*KSQLHealthcheckExternalKeys) Marshal 

func (m *KSQLHealthcheckExternalKeys) Marshal() (dAtA []byte, err error)

func (*KSQLHealthcheckExternalKeys) MarshalTo 

func (m *KSQLHealthcheckExternalKeys) MarshalTo(dAtA []byte) (int, error)

func (*KSQLHealthcheckExternalKeys) ProtoMessage 

func (*KSQLHealthcheckExternalKeys) ProtoMessage()

func (*KSQLHealthcheckExternalKeys) Reset 

func (m *KSQLHealthcheckExternalKeys) Reset()

func (*KSQLHealthcheckExternalKeys) Size 

func (m *KSQLHealthcheckExternalKeys) Size() (n int)

func (*KSQLHealthcheckExternalKeys) String 

func (m *KSQLHealthcheckExternalKeys) String() string

func (*KSQLHealthcheckExternalKeys) Unmarshal 

func (m *KSQLHealthcheckExternalKeys) Unmarshal(dAtA []byte) error

func (*KSQLHealthcheckExternalKeys) XXX_DiscardUnknown 

func (m *KSQLHealthcheckExternalKeys) XXX_DiscardUnknown()

func (*KSQLHealthcheckExternalKeys) XXX_Marshal 

func (m *KSQLHealthcheckExternalKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KSQLHealthcheckExternalKeys) XXX_Merge 

func (m *KSQLHealthcheckExternalKeys) XXX_Merge(src proto.Message)

func (*KSQLHealthcheckExternalKeys) XXX_Size 

func (m *KSQLHealthcheckExternalKeys) XXX_Size() int

func (*KSQLHealthcheckExternalKeys) XXX_Unmarshal 

func (m *KSQLHealthcheckExternalKeys) XXX_Unmarshal(b []byte) error

type KafkaHealthcheckExternalKeys 

type KafkaHealthcheckExternalKeys struct {
	KafkaKey             string   `` /* 136-byte string literal not displayed */
	KafkaSecret          string   `` /* 162-byte string literal not displayed */
	DdApiKey             string   `` /* 151-byte string literal not displayed */
	KafkaLinkKey         string   `` /* 160-byte string literal not displayed */
	KafkaLinkSecret      string   `` /* 186-byte string literal not displayed */
	KafkaRbacKey         string   `` /* 160-byte string literal not displayed */
	KafkaRbacSecret      string   `` /* 186-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaHealthcheckExternalKeys) Descriptor 

func (*KafkaHealthcheckExternalKeys) Descriptor() ([]byte, []int)

func (*KafkaHealthcheckExternalKeys) GetDdApiKey 

func (m *KafkaHealthcheckExternalKeys) GetDdApiKey() string

func (*KafkaHealthcheckExternalKeys) GetKafkaKey 

func (m *KafkaHealthcheckExternalKeys) GetKafkaKey() string

func (*KafkaHealthcheckExternalKeys) GetKafkaLinkKey 

func (m *KafkaHealthcheckExternalKeys) GetKafkaLinkKey() string

func (*KafkaHealthcheckExternalKeys) GetKafkaLinkSecret 

func (m *KafkaHealthcheckExternalKeys) GetKafkaLinkSecret() string

func (*KafkaHealthcheckExternalKeys) GetKafkaRbacKey 

func (m *KafkaHealthcheckExternalKeys) GetKafkaRbacKey() string

func (*KafkaHealthcheckExternalKeys) GetKafkaRbacSecret 

func (m *KafkaHealthcheckExternalKeys) GetKafkaRbacSecret() string

func (*KafkaHealthcheckExternalKeys) GetKafkaSecret 

func (m *KafkaHealthcheckExternalKeys) GetKafkaSecret() string

func (*KafkaHealthcheckExternalKeys) Marshal 

func (m *KafkaHealthcheckExternalKeys) Marshal() (dAtA []byte, err error)

func (*KafkaHealthcheckExternalKeys) MarshalTo 

func (m *KafkaHealthcheckExternalKeys) MarshalTo(dAtA []byte) (int, error)

func (*KafkaHealthcheckExternalKeys) ProtoMessage 

func (*KafkaHealthcheckExternalKeys) ProtoMessage()

func (*KafkaHealthcheckExternalKeys) Reset 

func (m *KafkaHealthcheckExternalKeys) Reset()

func (*KafkaHealthcheckExternalKeys) Size 

func (m *KafkaHealthcheckExternalKeys) Size() (n int)

func (*KafkaHealthcheckExternalKeys) String 

func (m *KafkaHealthcheckExternalKeys) String() string

func (*KafkaHealthcheckExternalKeys) Unmarshal 

func (m *KafkaHealthcheckExternalKeys) Unmarshal(dAtA []byte) error

func (*KafkaHealthcheckExternalKeys) XXX_DiscardUnknown 

func (m *KafkaHealthcheckExternalKeys) XXX_DiscardUnknown()

func (*KafkaHealthcheckExternalKeys) XXX_Marshal 

func (m *KafkaHealthcheckExternalKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KafkaHealthcheckExternalKeys) XXX_Merge 

func (m *KafkaHealthcheckExternalKeys) XXX_Merge(src proto.Message)

func (*KafkaHealthcheckExternalKeys) XXX_Size 

func (m *KafkaHealthcheckExternalKeys) XXX_Size() int

func (*KafkaHealthcheckExternalKeys) XXX_Unmarshal 

func (m *KafkaHealthcheckExternalKeys) XXX_Unmarshal(b []byte) error

type ListAccountsReply 

type ListAccountsReply struct {
	Accounts             []*Account `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty" db:"accounts,omitempty" url:"accounts,omitempty"`
	Error                *Error     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	PageInfo             *PageInfo  `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ListAccountsReply) Descriptor 

func (*ListAccountsReply) Descriptor() ([]byte, []int)

func (*ListAccountsReply) GetAccounts 

func (m *ListAccountsReply) GetAccounts() []*Account

func (*ListAccountsReply) GetError 

func (m *ListAccountsReply) GetError() *Error

func (*ListAccountsReply) GetPageInfo 

func (m *ListAccountsReply) GetPageInfo() *PageInfo

func (*ListAccountsReply) Marshal 

func (m *ListAccountsReply) Marshal() (dAtA []byte, err error)

func (*ListAccountsReply) MarshalTo 

func (m *ListAccountsReply) MarshalTo(dAtA []byte) (int, error)

func (*ListAccountsReply) ProtoMessage 

func (*ListAccountsReply) ProtoMessage()

func (*ListAccountsReply) Reset 

func (m *ListAccountsReply) Reset()

func (*ListAccountsReply) Size 

func (m *ListAccountsReply) Size() (n int)

func (*ListAccountsReply) String 

func (m *ListAccountsReply) String() string

func (*ListAccountsReply) Unmarshal 

func (m *ListAccountsReply) Unmarshal(dAtA []byte) error

func (*ListAccountsReply) XXX_DiscardUnknown 

func (m *ListAccountsReply) XXX_DiscardUnknown()

func (*ListAccountsReply) XXX_Marshal 

func (m *ListAccountsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAccountsReply) XXX_Merge 

func (m *ListAccountsReply) XXX_Merge(src proto.Message)

func (*ListAccountsReply) XXX_Size 

func (m *ListAccountsReply) XXX_Size() int

func (*ListAccountsReply) XXX_Unmarshal 

func (m *ListAccountsReply) XXX_Unmarshal(b []byte) error

type Logger 

type Logger interface {
	Debug(...interface{})
	Debugf(string, ...interface{})
	Info(...interface{})
	Infof(string, ...interface{})
	Warn(...interface{})
	Warnf(string, ...interface{})
	Error(...interface{})
	Errorf(string, ...interface{})
}

Logger provides an interface that will be used for all logging in this client. User provided logging implementations must conform to this interface. Popular loggers like zap and logrus already implement this interface.

type LoggingHttpClient 

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

Proxy for HTTP client for logging

func (*LoggingHttpClient) Do 

func (c *LoggingHttpClient) Do(req *http.Request) (*http.Response, error)

type Marketplace 

type Marketplace struct {
	Partner              MarketplacePartner       `` /* 151-byte string literal not displayed */
	CustomerId           string                   `` /* 146-byte string literal not displayed */
	CustomerState        MarketplaceCustomerState `` /* 203-byte string literal not displayed */
	ConsoleIntegrated    bool                     `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Marketplace) Descriptor 

func (*Marketplace) Descriptor() ([]byte, []int)

func (*Marketplace) GetConsoleIntegrated 

func (m *Marketplace) GetConsoleIntegrated() bool

func (*Marketplace) GetCustomerId 

func (m *Marketplace) GetCustomerId() string

func (*Marketplace) GetCustomerState 

func (m *Marketplace) GetCustomerState() MarketplaceCustomerState

func (*Marketplace) GetPartner 

func (m *Marketplace) GetPartner() MarketplacePartner

func (*Marketplace) Marshal 

func (m *Marketplace) Marshal() (dAtA []byte, err error)

func (*Marketplace) MarshalTo 

func (m *Marketplace) MarshalTo(dAtA []byte) (int, error)

func (*Marketplace) ProtoMessage 

func (*Marketplace) ProtoMessage()

func (*Marketplace) Reset 

func (m *Marketplace) Reset()

func (*Marketplace) Size 

func (m *Marketplace) Size() (n int)

func (*Marketplace) String 

func (m *Marketplace) String() string

func (*Marketplace) Unmarshal 

func (m *Marketplace) Unmarshal(dAtA []byte) error

func (*Marketplace) XXX_DiscardUnknown 

func (m *Marketplace) XXX_DiscardUnknown()

func (*Marketplace) XXX_Marshal 

func (m *Marketplace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Marketplace) XXX_Merge 

func (m *Marketplace) XXX_Merge(src proto.Message)

func (*Marketplace) XXX_Size 

func (m *Marketplace) XXX_Size() int

func (*Marketplace) XXX_Unmarshal 

func (m *Marketplace) XXX_Unmarshal(b []byte) error

type MarketplaceCreds 

type MarketplaceCreds struct {
	Token                string             `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty" db:"token,omitempty" url:"token,omitempty"`
	Partner              MarketplacePartner `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

TODO remove with CDMUM-789

func (*MarketplaceCreds) Descriptor 

func (*MarketplaceCreds) Descriptor() ([]byte, []int)

func (*MarketplaceCreds) GetPartner 

func (m *MarketplaceCreds) GetPartner() MarketplacePartner

func (*MarketplaceCreds) GetToken 

func (m *MarketplaceCreds) GetToken() string

func (*MarketplaceCreds) Marshal 

func (m *MarketplaceCreds) Marshal() (dAtA []byte, err error)

func (*MarketplaceCreds) MarshalTo 

func (m *MarketplaceCreds) MarshalTo(dAtA []byte) (int, error)

func (*MarketplaceCreds) ProtoMessage 

func (*MarketplaceCreds) ProtoMessage()

func (*MarketplaceCreds) Reset 

func (m *MarketplaceCreds) Reset()

func (*MarketplaceCreds) Size 

func (m *MarketplaceCreds) Size() (n int)

func (*MarketplaceCreds) String 

func (m *MarketplaceCreds) String() string

func (*MarketplaceCreds) Unmarshal 

func (m *MarketplaceCreds) Unmarshal(dAtA []byte) error

func (*MarketplaceCreds) XXX_DiscardUnknown 

func (m *MarketplaceCreds) XXX_DiscardUnknown()

func (*MarketplaceCreds) XXX_Marshal 

func (m *MarketplaceCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarketplaceCreds) XXX_Merge 

func (m *MarketplaceCreds) XXX_Merge(src proto.Message)

func (*MarketplaceCreds) XXX_Size 

func (m *MarketplaceCreds) XXX_Size() int

func (*MarketplaceCreds) XXX_Unmarshal 

func (m *MarketplaceCreds) XXX_Unmarshal(b []byte) error

type MarketplaceCustomerState 

type MarketplaceCustomerState int32
const (
	MarketplaceCustomerState_CUSTOMER_APPROVAL_PENDING MarketplaceCustomerState = 0
	MarketplaceCustomerState_CUSTOMER_APPROVAL_SENT    MarketplaceCustomerState = 1
	MarketplaceCustomerState_CUSTOMER_APPROVED         MarketplaceCustomerState = 2
	MarketplaceCustomerState_CUSTOMER_DELETED          MarketplaceCustomerState = 3
)

func (MarketplaceCustomerState) EnumDescriptor 

func (MarketplaceCustomerState) EnumDescriptor() ([]byte, []int)

func (MarketplaceCustomerState) String 

func (x MarketplaceCustomerState) String() string

type MarketplacePartner 

type MarketplacePartner int32
const (
	MarketplacePartner_UNKNOWN MarketplacePartner = 0
	MarketplacePartner_GCP     MarketplacePartner = 1
	MarketplacePartner_AWS     MarketplacePartner = 2
	MarketplacePartner_AZURE   MarketplacePartner = 3
)

func (MarketplacePartner) EnumDescriptor 

func (MarketplacePartner) EnumDescriptor() ([]byte, []int)

func (MarketplacePartner) String 

func (x MarketplacePartner) String() string

type MarketplaceSubscription 

type MarketplaceSubscription int32
const (
	MarketplaceSubscription_SUBSCRIPTION_NONE    MarketplaceSubscription = 0
	MarketplaceSubscription_SUBSCRIPTION_PENDING MarketplaceSubscription = 1
	MarketplaceSubscription_SUBSCRIPTION_ACTIVE  MarketplaceSubscription = 2
)

func (MarketplaceSubscription) EnumDescriptor 

func (MarketplaceSubscription) EnumDescriptor() ([]byte, []int)

func (MarketplaceSubscription) String 

func (x MarketplaceSubscription) String() string

type NetworkType 

type NetworkType int32
const (
	NetworkType_UNKNOWN_TYPE    NetworkType = 0
	NetworkType_PUBLIC          NetworkType = 1
	NetworkType_PRIVATE_LINK    NetworkType = 2
	NetworkType_TRANSIT_GATEWAY NetworkType = 3
	NetworkType_VPC_PEERING     NetworkType = 4
	// INTERNAL requires that source traffic origniates from the NetworkRegion's requested CIDR.
	NetworkType_INTERNAL NetworkType = 5
)

func (NetworkType) EnumDescriptor 

func (NetworkType) EnumDescriptor() ([]byte, []int)

func (NetworkType) String 

func (x NetworkType) String() string

type Organization 

type Organization struct {
	Id               int32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	Name             string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	Deactivated      bool             `` /* 131-byte string literal not displayed */
	StripeCustomerId string           `` /* 180-byte string literal not displayed */
	Created          *types.Timestamp `protobuf:"bytes,5,opt,name=created,proto3" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified         *types.Timestamp `protobuf:"bytes,6,opt,name=modified,proto3" json:"modified,omitempty" db:"modified,omitempty" url:"modified,omitempty"`
	BillingEmail     string           `` /* 156-byte string literal not displayed */
	Plan             *Plan            `protobuf:"bytes,8,opt,name=plan,proto3" json:"plan,omitempty" db:"plan,omitempty" url:"plan,omitempty"`
	Saml             *Saml            `protobuf:"bytes,9,opt,name=saml,proto3" json:"saml,omitempty" db:"saml,omitempty" url:"saml,omitempty"`
	Sso              *Sso             `protobuf:"bytes,10,opt,name=sso,proto3" json:"sso,omitempty" db:"sso,omitempty" url:"sso,omitempty"`
	Marketplace      *Marketplace     `` /* 131-byte string literal not displayed */
	ResourceId       string           `` /* 147-byte string literal not displayed */
	//derived flags
	HasEntitlement bool      `` /* 168-byte string literal not displayed */
	ShowBilling    bool      `` /* 153-byte string literal not displayed */
	AuditLog       *AuditLog `` /* 137-byte string literal not displayed */
	// Derived flag from active orders (based on the current time), indicating if an org has commitment with us.
	HasCommitment bool `` // Deprecated: Do not use.
	/* 163-byte string literal not displayed */
	//derived marketplace subscription
	MarketplaceSubscription MarketplaceSubscription `` /* 253-byte string literal not displayed */
	DeactivatedAt           *types.Timestamp        `` /* 162-byte string literal not displayed */
	SuspensionStatus        *SuspensionStatus       `` /* 177-byte string literal not displayed */
	DisplayLabel            string                  `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                `json:"-"`
	XXX_unrecognized        []byte                  `json:"-"`
	XXX_sizecache           int32                   `json:"-"`
}

func (*Organization) Descriptor 

func (*Organization) Descriptor() ([]byte, []int)

func (*Organization) GetAuditLog 

func (m *Organization) GetAuditLog() *AuditLog

func (*Organization) GetBillingEmail 

func (m *Organization) GetBillingEmail() string

func (*Organization) GetCreated 

func (m *Organization) GetCreated() *types.Timestamp

func (*Organization) GetDeactivated 

func (m *Organization) GetDeactivated() bool

func (*Organization) GetDeactivatedAt 

func (m *Organization) GetDeactivatedAt() *types.Timestamp

func (*Organization) GetDisplayLabel 

func (m *Organization) GetDisplayLabel() string

func (*Organization) GetHasCommitment deprecated 

func (m *Organization) GetHasCommitment() bool

Deprecated: Do not use.

func (*Organization) GetHasEntitlement 

func (m *Organization) GetHasEntitlement() bool

func (*Organization) GetId 

func (m *Organization) GetId() int32

func (*Organization) GetMarketplace 

func (m *Organization) GetMarketplace() *Marketplace

func (*Organization) GetMarketplaceSubscription 

func (m *Organization) GetMarketplaceSubscription() MarketplaceSubscription

func (*Organization) GetModified 

func (m *Organization) GetModified() *types.Timestamp

func (*Organization) GetName 

func (m *Organization) GetName() string

func (*Organization) GetPlan 

func (m *Organization) GetPlan() *Plan

func (*Organization) GetResourceId 

func (m *Organization) GetResourceId() string

func (*Organization) GetSaml 

func (m *Organization) GetSaml() *Saml

func (*Organization) GetShowBilling 

func (m *Organization) GetShowBilling() bool

func (*Organization) GetSso 

func (m *Organization) GetSso() *Sso

func (*Organization) GetStripeCustomerId 

func (m *Organization) GetStripeCustomerId() string

func (*Organization) GetSuspensionStatus 

func (m *Organization) GetSuspensionStatus() *SuspensionStatus

func (*Organization) Marshal 

func (m *Organization) Marshal() (dAtA []byte, err error)

func (*Organization) MarshalTo 

func (m *Organization) MarshalTo(dAtA []byte) (int, error)

func (*Organization) ProtoMessage 

func (*Organization) ProtoMessage()

func (*Organization) Reset 

func (m *Organization) Reset()

func (*Organization) Size 

func (m *Organization) Size() (n int)

func (*Organization) String 

func (m *Organization) String() string

func (*Organization) Unmarshal 

func (m *Organization) Unmarshal(dAtA []byte) error

func (*Organization) XXX_DiscardUnknown 

func (m *Organization) XXX_DiscardUnknown()

func (*Organization) XXX_Marshal 

func (m *Organization) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Organization) XXX_Merge 

func (m *Organization) XXX_Merge(src proto.Message)

func (*Organization) XXX_Size 

func (m *Organization) XXX_Size() int

func (*Organization) XXX_Unmarshal 

func (m *Organization) XXX_Unmarshal(b []byte) error

type PageInfo 

type PageInfo struct {
	PageSize             int32    `` /* 137-byte string literal not displayed */
	PageToken            string   `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PageInfo) Descriptor 

func (*PageInfo) Descriptor() ([]byte, []int)

func (*PageInfo) GetPageSize 

func (m *PageInfo) GetPageSize() int32

func (*PageInfo) GetPageToken 

func (m *PageInfo) GetPageToken() string

func (*PageInfo) Marshal 

func (m *PageInfo) Marshal() (dAtA []byte, err error)

func (*PageInfo) MarshalTo 

func (m *PageInfo) MarshalTo(dAtA []byte) (int, error)

func (*PageInfo) ProtoMessage 

func (*PageInfo) ProtoMessage()

func (*PageInfo) Reset 

func (m *PageInfo) Reset()

func (*PageInfo) Size 

func (m *PageInfo) Size() (n int)

func (*PageInfo) String 

func (m *PageInfo) String() string

func (*PageInfo) Unmarshal 

func (m *PageInfo) Unmarshal(dAtA []byte) error

func (*PageInfo) XXX_DiscardUnknown 

func (m *PageInfo) XXX_DiscardUnknown()

func (*PageInfo) XXX_Marshal 

func (m *PageInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PageInfo) XXX_Merge 

func (m *PageInfo) XXX_Merge(src proto.Message)

func (*PageInfo) XXX_Size 

func (m *PageInfo) XXX_Size() int

func (*PageInfo) XXX_Unmarshal 

func (m *PageInfo) XXX_Unmarshal(b []byte) error

type Params 

type Params struct {
	BaseURL        string
	UserAgent      string
	BaseClient     *http.Client // all sling clients should extend from this (e.g., kafka-api with diff auth token)
	HttpClient     *http.Client // this is the http client for the cloud APIs
	Logger         Logger
	MetricsBaseURL string
}

type Plan 

type Plan struct {
	TaxAddress           *Address         `` /* 146-byte string literal not displayed */
	ProductLevel         ProductLevel     `` /* 186-byte string literal not displayed */
	TrialStart           *types.Timestamp `` /* 146-byte string literal not displayed */
	TrialEnd             *types.Timestamp `` /* 136-byte string literal not displayed */
	PlanStart            *types.Timestamp `` /* 141-byte string literal not displayed */
	PlanEnd              *types.Timestamp `` /* 131-byte string literal not displayed */
	Product              *Plan_Product    `protobuf:"bytes,8,opt,name=product,proto3" json:"product,omitempty" db:"product,omitempty" url:"product,omitempty"`
	Billing              *Plan_Billing    `protobuf:"bytes,9,opt,name=billing,proto3" json:"billing,omitempty" db:"billing,omitempty" url:"billing,omitempty"`
	ReferralCode         string           `` /* 157-byte string literal not displayed */
	AcceptTos            *types.BoolValue `` /* 142-byte string literal not displayed */
	AllowMultiTenant     bool             `` /* 182-byte string literal not displayed */
	AcceptTosPlatform    *types.BoolValue `` /* 186-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Plan) Descriptor 

func (*Plan) Descriptor() ([]byte, []int)

func (*Plan) GetAcceptTos 

func (m *Plan) GetAcceptTos() *types.BoolValue

func (*Plan) GetAcceptTosPlatform 

func (m *Plan) GetAcceptTosPlatform() *types.BoolValue

func (*Plan) GetAllowMultiTenant 

func (m *Plan) GetAllowMultiTenant() bool

func (*Plan) GetBilling 

func (m *Plan) GetBilling() *Plan_Billing

func (*Plan) GetPlanEnd 

func (m *Plan) GetPlanEnd() *types.Timestamp

func (*Plan) GetPlanStart 

func (m *Plan) GetPlanStart() *types.Timestamp

func (*Plan) GetProduct 

func (m *Plan) GetProduct() *Plan_Product

func (*Plan) GetProductLevel 

func (m *Plan) GetProductLevel() ProductLevel

func (*Plan) GetReferralCode 

func (m *Plan) GetReferralCode() string

func (*Plan) GetTaxAddress 

func (m *Plan) GetTaxAddress() *Address

func (*Plan) GetTrialEnd 

func (m *Plan) GetTrialEnd() *types.Timestamp

func (*Plan) GetTrialStart 

func (m *Plan) GetTrialStart() *types.Timestamp

func (*Plan) Marshal 

func (m *Plan) Marshal() (dAtA []byte, err error)

func (*Plan) MarshalTo 

func (m *Plan) MarshalTo(dAtA []byte) (int, error)

func (*Plan) ProtoMessage 

func (*Plan) ProtoMessage()

func (*Plan) Reset 

func (m *Plan) Reset()

func (*Plan) Size 

func (m *Plan) Size() (n int)

func (*Plan) String 

func (m *Plan) String() string

func (*Plan) Unmarshal 

func (m *Plan) Unmarshal(dAtA []byte) error

func (*Plan) XXX_DiscardUnknown 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal 

func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan) XXX_Merge 

func (m *Plan) XXX_Merge(src proto.Message)

func (*Plan) XXX_Size 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal 

func (m *Plan) XXX_Unmarshal(b []byte) error

type Plan_Billing 

type Plan_Billing struct {
	Method   BillingMethod   `` /* 141-byte string literal not displayed */
	Interval BillingInterval `` /* 151-byte string literal not displayed */
	// in hundredths of a cent, aggregates the running cost of all clusters
	// in the current billing cycle
	AccruedThisCycle     uint64   `` /* 181-byte string literal not displayed */
	StripeCustomerId     string   `` /* 180-byte string literal not displayed */
	Email                string   `protobuf:"bytes,5,opt,name=email,proto3" json:"email,omitempty" db:"email,omitempty" url:"email,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Plan_Billing) Descriptor 

func (*Plan_Billing) Descriptor() ([]byte, []int)

func (*Plan_Billing) GetAccruedThisCycle 

func (m *Plan_Billing) GetAccruedThisCycle() uint64

func (*Plan_Billing) GetEmail 

func (m *Plan_Billing) GetEmail() string

func (*Plan_Billing) GetInterval 

func (m *Plan_Billing) GetInterval() BillingInterval

func (*Plan_Billing) GetMethod 

func (m *Plan_Billing) GetMethod() BillingMethod

func (*Plan_Billing) GetStripeCustomerId 

func (m *Plan_Billing) GetStripeCustomerId() string

func (*Plan_Billing) Marshal 

func (m *Plan_Billing) Marshal() (dAtA []byte, err error)

func (*Plan_Billing) MarshalTo 

func (m *Plan_Billing) MarshalTo(dAtA []byte) (int, error)

func (*Plan_Billing) ProtoMessage 

func (*Plan_Billing) ProtoMessage()

func (*Plan_Billing) Reset 

func (m *Plan_Billing) Reset()

func (*Plan_Billing) Size 

func (m *Plan_Billing) Size() (n int)

func (*Plan_Billing) String 

func (m *Plan_Billing) String() string

func (*Plan_Billing) Unmarshal 

func (m *Plan_Billing) Unmarshal(dAtA []byte) error

func (*Plan_Billing) XXX_DiscardUnknown 

func (m *Plan_Billing) XXX_DiscardUnknown()

func (*Plan_Billing) XXX_Marshal 

func (m *Plan_Billing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan_Billing) XXX_Merge 

func (m *Plan_Billing) XXX_Merge(src proto.Message)

func (*Plan_Billing) XXX_Size 

func (m *Plan_Billing) XXX_Size() int

func (*Plan_Billing) XXX_Unmarshal 

func (m *Plan_Billing) XXX_Unmarshal(b []byte) error

type Plan_Product 

type Plan_Product struct {
	ReadThroughputMb  float64 `` /* 182-byte string literal not displayed */
	WriteThroughputMb float64 `` /* 187-byte string literal not displayed */
	// max data that can be retained, usable, not counting total allocated for replication
	StorageGb            int32    `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Plan_Product) Descriptor 

func (*Plan_Product) Descriptor() ([]byte, []int)

func (*Plan_Product) GetReadThroughputMb 

func (m *Plan_Product) GetReadThroughputMb() float64

func (*Plan_Product) GetStorageGb 

func (m *Plan_Product) GetStorageGb() int32

func (*Plan_Product) GetWriteThroughputMb 

func (m *Plan_Product) GetWriteThroughputMb() float64

func (*Plan_Product) Marshal 

func (m *Plan_Product) Marshal() (dAtA []byte, err error)

func (*Plan_Product) MarshalTo 

func (m *Plan_Product) MarshalTo(dAtA []byte) (int, error)

func (*Plan_Product) ProtoMessage 

func (*Plan_Product) ProtoMessage()

func (*Plan_Product) Reset 

func (m *Plan_Product) Reset()

func (*Plan_Product) Size 

func (m *Plan_Product) Size() (n int)

func (*Plan_Product) String 

func (m *Plan_Product) String() string

func (*Plan_Product) Unmarshal 

func (m *Plan_Product) Unmarshal(dAtA []byte) error

func (*Plan_Product) XXX_DiscardUnknown 

func (m *Plan_Product) XXX_DiscardUnknown()

func (*Plan_Product) XXX_Marshal 

func (m *Plan_Product) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan_Product) XXX_Merge 

func (m *Plan_Product) XXX_Merge(src proto.Message)

func (*Plan_Product) XXX_Size 

func (m *Plan_Product) XXX_Size() int

func (*Plan_Product) XXX_Unmarshal 

func (m *Plan_Product) XXX_Unmarshal(b []byte) error

type PriceTable 

type PriceTable struct {
	PriceTable           map[string]*UnitPrices `` /* 234-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*PriceTable) Descriptor 

func (*PriceTable) Descriptor() ([]byte, []int)

func (*PriceTable) GetPriceTable 

func (m *PriceTable) GetPriceTable() map[string]*UnitPrices

func (*PriceTable) Marshal 

func (m *PriceTable) Marshal() (dAtA []byte, err error)

func (*PriceTable) MarshalTo 

func (m *PriceTable) MarshalTo(dAtA []byte) (int, error)

func (*PriceTable) ProtoMessage 

func (*PriceTable) ProtoMessage()

func (*PriceTable) Reset 

func (m *PriceTable) Reset()

func (*PriceTable) Size 

func (m *PriceTable) Size() (n int)

func (*PriceTable) String 

func (m *PriceTable) String() string

func (*PriceTable) Unmarshal 

func (m *PriceTable) Unmarshal(dAtA []byte) error

func (*PriceTable) XXX_DiscardUnknown 

func (m *PriceTable) XXX_DiscardUnknown()

func (*PriceTable) XXX_Marshal 

func (m *PriceTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PriceTable) XXX_Merge 

func (m *PriceTable) XXX_Merge(src proto.Message)

func (*PriceTable) XXX_Size 

func (m *PriceTable) XXX_Size() int

func (*PriceTable) XXX_Unmarshal 

func (m *PriceTable) XXX_Unmarshal(b []byte) error

type ProductLevel 

type ProductLevel int32
const (
	ProductLevel_DEVELOPER  ProductLevel = 0
	ProductLevel_TEAM       ProductLevel = 1
	ProductLevel_ENTERPRISE ProductLevel = 2
	ProductLevel_UNIFIED    ProductLevel = 3
)

func (ProductLevel) EnumDescriptor 

func (ProductLevel) EnumDescriptor() ([]byte, []int)

func (ProductLevel) String 

func (x ProductLevel) String() string

type PromoCodeClaim 

type PromoCodeClaim struct {
	OrgId                int32            `protobuf:"varint,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty" db:"org_id,omitempty" url:"org_id,omitempty"`
	Code                 string           `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty" db:"code,omitempty" url:"code,omitempty"`
	Amount               int64            `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty" db:"amount,omitempty" url:"amount,omitempty"`
	Balance              int64            `protobuf:"varint,4,opt,name=balance,proto3" json:"balance,omitempty" db:"balance,omitempty" url:"balance,omitempty"`
	ClaimDate            *types.Timestamp `` /* 141-byte string literal not displayed */
	CreditExpirationDate *types.Timestamp `` /* 200-byte string literal not displayed */
	ClaimedBy            int32            `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PromoCodeClaim) Descriptor 

func (*PromoCodeClaim) Descriptor() ([]byte, []int)

func (*PromoCodeClaim) GetAmount 

func (m *PromoCodeClaim) GetAmount() int64

func (*PromoCodeClaim) GetBalance 

func (m *PromoCodeClaim) GetBalance() int64

func (*PromoCodeClaim) GetClaimDate 

func (m *PromoCodeClaim) GetClaimDate() *types.Timestamp

func (*PromoCodeClaim) GetClaimedBy 

func (m *PromoCodeClaim) GetClaimedBy() int32

func (*PromoCodeClaim) GetCode 

func (m *PromoCodeClaim) GetCode() string

func (*PromoCodeClaim) GetCreditExpirationDate 

func (m *PromoCodeClaim) GetCreditExpirationDate() *types.Timestamp

func (*PromoCodeClaim) GetOrgId 

func (m *PromoCodeClaim) GetOrgId() int32

func (*PromoCodeClaim) Marshal 

func (m *PromoCodeClaim) Marshal() (dAtA []byte, err error)

func (*PromoCodeClaim) MarshalTo 

func (m *PromoCodeClaim) MarshalTo(dAtA []byte) (int, error)

func (*PromoCodeClaim) ProtoMessage 

func (*PromoCodeClaim) ProtoMessage()

func (*PromoCodeClaim) Reset 

func (m *PromoCodeClaim) Reset()

func (*PromoCodeClaim) Size 

func (m *PromoCodeClaim) Size() (n int)

func (*PromoCodeClaim) String 

func (m *PromoCodeClaim) String() string

func (*PromoCodeClaim) Unmarshal 

func (m *PromoCodeClaim) Unmarshal(dAtA []byte) error

func (*PromoCodeClaim) XXX_DiscardUnknown 

func (m *PromoCodeClaim) XXX_DiscardUnknown()

func (*PromoCodeClaim) XXX_Marshal 

func (m *PromoCodeClaim) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PromoCodeClaim) XXX_Merge 

func (m *PromoCodeClaim) XXX_Merge(src proto.Message)

func (*PromoCodeClaim) XXX_Size 

func (m *PromoCodeClaim) XXX_Size() int

func (*PromoCodeClaim) XXX_Unmarshal 

func (m *PromoCodeClaim) XXX_Unmarshal(b []byte) error

type ReadinessHealthCheckReply 

type ReadinessHealthCheckReply struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" db:"message,omitempty" url:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadinessHealthCheckReply) Descriptor 

func (*ReadinessHealthCheckReply) Descriptor() ([]byte, []int)

func (*ReadinessHealthCheckReply) GetError 

func (m *ReadinessHealthCheckReply) GetError() *Error

func (*ReadinessHealthCheckReply) GetMessage 

func (m *ReadinessHealthCheckReply) GetMessage() string

func (*ReadinessHealthCheckReply) Marshal 

func (m *ReadinessHealthCheckReply) Marshal() (dAtA []byte, err error)

func (*ReadinessHealthCheckReply) MarshalTo 

func (m *ReadinessHealthCheckReply) MarshalTo(dAtA []byte) (int, error)

func (*ReadinessHealthCheckReply) ProtoMessage 

func (*ReadinessHealthCheckReply) ProtoMessage()

func (*ReadinessHealthCheckReply) Reset 

func (m *ReadinessHealthCheckReply) Reset()

func (*ReadinessHealthCheckReply) Size 

func (m *ReadinessHealthCheckReply) Size() (n int)

func (*ReadinessHealthCheckReply) String 

func (m *ReadinessHealthCheckReply) String() string

func (*ReadinessHealthCheckReply) Unmarshal 

func (m *ReadinessHealthCheckReply) Unmarshal(dAtA []byte) error

func (*ReadinessHealthCheckReply) XXX_DiscardUnknown 

func (m *ReadinessHealthCheckReply) XXX_DiscardUnknown()

func (*ReadinessHealthCheckReply) XXX_Marshal 

func (m *ReadinessHealthCheckReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadinessHealthCheckReply) XXX_Merge 

func (m *ReadinessHealthCheckReply) XXX_Merge(src proto.Message)

func (*ReadinessHealthCheckReply) XXX_Size 

func (m *ReadinessHealthCheckReply) XXX_Size() int

func (*ReadinessHealthCheckReply) XXX_Unmarshal 

func (m *ReadinessHealthCheckReply) XXX_Unmarshal(b []byte) error

type ReadinessHealthCheckRequest 

type ReadinessHealthCheckRequest struct {
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	Error                *Error            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ReadinessHealthCheckRequest) Descriptor 

func (*ReadinessHealthCheckRequest) Descriptor() ([]byte, []int)

func (*ReadinessHealthCheckRequest) GetError 

func (m *ReadinessHealthCheckRequest) GetError() *Error

func (*ReadinessHealthCheckRequest) GetRequestCarrier 

func (m *ReadinessHealthCheckRequest) GetRequestCarrier() map[string]string

func (*ReadinessHealthCheckRequest) Marshal 

func (m *ReadinessHealthCheckRequest) Marshal() (dAtA []byte, err error)

func (*ReadinessHealthCheckRequest) MarshalTo 

func (m *ReadinessHealthCheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadinessHealthCheckRequest) ProtoMessage 

func (*ReadinessHealthCheckRequest) ProtoMessage()

func (*ReadinessHealthCheckRequest) Reset 

func (m *ReadinessHealthCheckRequest) Reset()

func (*ReadinessHealthCheckRequest) Size 

func (m *ReadinessHealthCheckRequest) Size() (n int)

func (*ReadinessHealthCheckRequest) String 

func (m *ReadinessHealthCheckRequest) String() string

func (*ReadinessHealthCheckRequest) Unmarshal 

func (m *ReadinessHealthCheckRequest) Unmarshal(dAtA []byte) error

func (*ReadinessHealthCheckRequest) XXX_DiscardUnknown 

func (m *ReadinessHealthCheckRequest) XXX_DiscardUnknown()

func (*ReadinessHealthCheckRequest) XXX_Marshal 

func (m *ReadinessHealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadinessHealthCheckRequest) XXX_Merge 

func (m *ReadinessHealthCheckRequest) XXX_Merge(src proto.Message)

func (*ReadinessHealthCheckRequest) XXX_Size 

func (m *ReadinessHealthCheckRequest) XXX_Size() int

func (*ReadinessHealthCheckRequest) XXX_Unmarshal 

func (m *ReadinessHealthCheckRequest) XXX_Unmarshal(b []byte) error

type Region 

type Region struct {
	Id    string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	Cloud string              `protobuf:"bytes,2,opt,name=cloud,proto3" json:"cloud,omitempty" db:"cloud,omitempty" url:"cloud,omitempty"`
	Zones []*AvailabilityZone `protobuf:"bytes,3,rep,name=zones,proto3" json:"zones,omitempty" db:"zones,omitempty" url:"zones,omitempty"`
	Name  string              `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	// This field will be calcuated at runtime. Default to false
	// e.g. when there is available physical cluster for logical cluster provision, it will be set to true
	IsSchedulable bool `` /* 162-byte string literal not displayed */
	// This field will be calcuated at runtime. Default to false
	// e.g. when there is available physical cluster for logical cluster provision, and its Durability==High, it will be set to true
	IsMultizoneEnabled bool           `` /* 191-byte string literal not displayed */
	Config             *Region_Config `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty" db:"config,omitempty" url:"config,omitempty"`
	// This is a vanity field. This means that it is not persisted to the DB
	// but computed at runtime.
	Schedulability       *Schedulability `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Region) Descriptor 

func (*Region) Descriptor() ([]byte, []int)

func (*Region) GetCloud 

func (m *Region) GetCloud() string

func (*Region) GetConfig 

func (m *Region) GetConfig() *Region_Config

func (*Region) GetId 

func (m *Region) GetId() string

func (*Region) GetIsMultizoneEnabled 

func (m *Region) GetIsMultizoneEnabled() bool

func (*Region) GetIsSchedulable 

func (m *Region) GetIsSchedulable() bool

func (*Region) GetName 

func (m *Region) GetName() string

func (*Region) GetSchedulability 

func (m *Region) GetSchedulability() *Schedulability

func (*Region) GetZones 

func (m *Region) GetZones() []*AvailabilityZone

func (*Region) Marshal 

func (m *Region) Marshal() (dAtA []byte, err error)

func (*Region) MarshalTo 

func (m *Region) MarshalTo(dAtA []byte) (int, error)

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) Reset 

func (m *Region) Reset()

func (*Region) Size 

func (m *Region) Size() (n int)

func (*Region) String 

func (m *Region) String() string

func (*Region) Unmarshal 

func (m *Region) Unmarshal(dAtA []byte) error

func (*Region) XXX_DiscardUnknown 

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal 

func (m *Region) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Region) XXX_Merge 

func (m *Region) XXX_Merge(src proto.Message)

func (*Region) XXX_Size 

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal 

func (m *Region) XXX_Unmarshal(b []byte) error

type Region_Config 

type Region_Config struct {
	Docker               *Region_Docker `protobuf:"bytes,1,opt,name=docker,proto3" json:"docker,omitempty" db:"docker,omitempty" url:"docker,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Region_Config) Descriptor 

func (*Region_Config) Descriptor() ([]byte, []int)

func (*Region_Config) GetDocker 

func (m *Region_Config) GetDocker() *Region_Docker

func (*Region_Config) Marshal 

func (m *Region_Config) Marshal() (dAtA []byte, err error)

func (*Region_Config) MarshalTo 

func (m *Region_Config) MarshalTo(dAtA []byte) (int, error)

func (*Region_Config) ProtoMessage 

func (*Region_Config) ProtoMessage()

func (*Region_Config) Reset 

func (m *Region_Config) Reset()

func (*Region_Config) Scan 

func (t *Region_Config) Scan(val interface{}) error

func (*Region_Config) Size 

func (m *Region_Config) Size() (n int)

func (*Region_Config) String 

func (m *Region_Config) String() string

func (*Region_Config) Unmarshal 

func (m *Region_Config) Unmarshal(dAtA []byte) error

func (*Region_Config) Value 

func (t *Region_Config) Value() (driver.Value, error)

func (*Region_Config) XXX_DiscardUnknown 

func (m *Region_Config) XXX_DiscardUnknown()

func (*Region_Config) XXX_Marshal 

func (m *Region_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Region_Config) XXX_Merge 

func (m *Region_Config) XXX_Merge(src proto.Message)

func (*Region_Config) XXX_Size 

func (m *Region_Config) XXX_Size() int

func (*Region_Config) XXX_Unmarshal 

func (m *Region_Config) XXX_Unmarshal(b []byte) error

type Region_Docker 

type Region_Docker struct {
	Repo                 string   `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty" db:"repo,omitempty" url:"repo,omitempty"`
	ImagePrefix          string   `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Region_Docker) Descriptor 

func (*Region_Docker) Descriptor() ([]byte, []int)

func (*Region_Docker) GetImagePrefix 

func (m *Region_Docker) GetImagePrefix() string

func (*Region_Docker) GetRepo 

func (m *Region_Docker) GetRepo() string

func (*Region_Docker) Marshal 

func (m *Region_Docker) Marshal() (dAtA []byte, err error)

func (*Region_Docker) MarshalTo 

func (m *Region_Docker) MarshalTo(dAtA []byte) (int, error)

func (*Region_Docker) ProtoMessage 

func (*Region_Docker) ProtoMessage()

func (*Region_Docker) Reset 

func (m *Region_Docker) Reset()

func (*Region_Docker) Scan 

func (t *Region_Docker) Scan(val interface{}) error

func (*Region_Docker) Size 

func (m *Region_Docker) Size() (n int)

func (*Region_Docker) String 

func (m *Region_Docker) String() string

func (*Region_Docker) Unmarshal 

func (m *Region_Docker) Unmarshal(dAtA []byte) error

func (*Region_Docker) Value 

func (t *Region_Docker) Value() (driver.Value, error)

func (*Region_Docker) XXX_DiscardUnknown 

func (m *Region_Docker) XXX_DiscardUnknown()

func (*Region_Docker) XXX_Marshal 

func (m *Region_Docker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Region_Docker) XXX_Merge 

func (m *Region_Docker) XXX_Merge(src proto.Message)

func (*Region_Docker) XXX_Size 

func (m *Region_Docker) XXX_Size() int

func (*Region_Docker) XXX_Unmarshal 

func (m *Region_Docker) XXX_Unmarshal(b []byte) error

type Router 

type Router struct {
	Cloud                string   `protobuf:"bytes,1,opt,name=cloud,proto3" json:"cloud,omitempty" db:"cloud,omitempty" url:"cloud,omitempty"`
	Region               string   `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty" db:"region,omitempty" url:"region,omitempty"`
	K8SCluster           string   `` /* 146-byte string literal not displayed */
	Cluster              string   `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

How services know whether to operate on the msg or ignore. If the service was running in AWS for instance, and the router said the cloud was for "GCP" it'd ignore. Specified by the scheduler-service.

func (*Router) Descriptor 

func (*Router) Descriptor() ([]byte, []int)

func (*Router) GetCloud 

func (m *Router) GetCloud() string

func (*Router) GetCluster 

func (m *Router) GetCluster() string

func (*Router) GetK8SCluster 

func (m *Router) GetK8SCluster() string

func (*Router) GetRegion 

func (m *Router) GetRegion() string

func (*Router) Marshal 

func (m *Router) Marshal() (dAtA []byte, err error)

func (*Router) MarshalTo 

func (m *Router) MarshalTo(dAtA []byte) (int, error)

func (*Router) ProtoMessage 

func (*Router) ProtoMessage()

func (*Router) Reset 

func (m *Router) Reset()

func (*Router) Size 

func (m *Router) Size() (n int)

func (*Router) String 

func (m *Router) String() string

func (*Router) Unmarshal 

func (m *Router) Unmarshal(dAtA []byte) error

func (*Router) XXX_DiscardUnknown 

func (m *Router) XXX_DiscardUnknown()

func (*Router) XXX_Marshal 

func (m *Router) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Router) XXX_Merge 

func (m *Router) XXX_Merge(src proto.Message)

func (*Router) XXX_Size 

func (m *Router) XXX_Size() int

func (*Router) XXX_Unmarshal 

func (m *Router) XXX_Unmarshal(b []byte) error

type Saml 

type Saml struct {
	Enabled              bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty" db:"enabled,omitempty" url:"enabled,omitempty"`
	MetadataUrl          string   `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Saml) Descriptor 

func (*Saml) Descriptor() ([]byte, []int)

func (*Saml) GetEnabled 

func (m *Saml) GetEnabled() bool

func (*Saml) GetMetadataUrl 

func (m *Saml) GetMetadataUrl() string

func (*Saml) Marshal 

func (m *Saml) Marshal() (dAtA []byte, err error)

func (*Saml) MarshalTo 

func (m *Saml) MarshalTo(dAtA []byte) (int, error)

func (*Saml) ProtoMessage 

func (*Saml) ProtoMessage()

func (*Saml) Reset 

func (m *Saml) Reset()

func (*Saml) Size 

func (m *Saml) Size() (n int)

func (*Saml) String 

func (m *Saml) String() string

func (*Saml) Unmarshal 

func (m *Saml) Unmarshal(dAtA []byte) error

func (*Saml) XXX_DiscardUnknown 

func (m *Saml) XXX_DiscardUnknown()

func (*Saml) XXX_Marshal 

func (m *Saml) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Saml) XXX_Merge 

func (m *Saml) XXX_Merge(src proto.Message)

func (*Saml) XXX_Size 

func (m *Saml) XXX_Size() int

func (*Saml) XXX_Unmarshal 

func (m *Saml) XXX_Unmarshal(b []byte) error

type Schedulability 

type Schedulability struct {
	SharedNetwork        *Schedulability_Tenancy `` /* 161-byte string literal not displayed */
	DedicatedNetwork     *Schedulability_Tenancy `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Schedulability) Descriptor 

func (*Schedulability) Descriptor() ([]byte, []int)

func (*Schedulability) GetDedicatedNetwork 

func (m *Schedulability) GetDedicatedNetwork() *Schedulability_Tenancy

func (*Schedulability) GetSharedNetwork 

func (m *Schedulability) GetSharedNetwork() *Schedulability_Tenancy

func (*Schedulability) Marshal 

func (m *Schedulability) Marshal() (dAtA []byte, err error)

func (*Schedulability) MarshalTo 

func (m *Schedulability) MarshalTo(dAtA []byte) (int, error)

func (*Schedulability) ProtoMessage 

func (*Schedulability) ProtoMessage()

func (*Schedulability) Reset 

func (m *Schedulability) Reset()

func (*Schedulability) Size 

func (m *Schedulability) Size() (n int)

func (*Schedulability) String 

func (m *Schedulability) String() string

func (*Schedulability) Unmarshal 

func (m *Schedulability) Unmarshal(dAtA []byte) error

func (*Schedulability) XXX_DiscardUnknown 

func (m *Schedulability) XXX_DiscardUnknown()

func (*Schedulability) XXX_Marshal 

func (m *Schedulability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schedulability) XXX_Merge 

func (m *Schedulability) XXX_Merge(src proto.Message)

func (*Schedulability) XXX_Size 

func (m *Schedulability) XXX_Size() int

func (*Schedulability) XXX_Unmarshal 

func (m *Schedulability) XXX_Unmarshal(b []byte) error

type Schedulability_Tenancy 

type Schedulability_Tenancy struct {
	SharedCluster        *Schedulability_Tenancy_Durability `` /* 161-byte string literal not displayed */
	DedicatedCluster     *Schedulability_Tenancy_Durability `` /* 176-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*Schedulability_Tenancy) Descriptor 

func (*Schedulability_Tenancy) Descriptor() ([]byte, []int)

func (*Schedulability_Tenancy) GetDedicatedCluster 

func (m *Schedulability_Tenancy) GetDedicatedCluster() *Schedulability_Tenancy_Durability

func (*Schedulability_Tenancy) GetSharedCluster 

func (m *Schedulability_Tenancy) GetSharedCluster() *Schedulability_Tenancy_Durability

func (*Schedulability_Tenancy) Marshal 

func (m *Schedulability_Tenancy) Marshal() (dAtA []byte, err error)

func (*Schedulability_Tenancy) MarshalTo 

func (m *Schedulability_Tenancy) MarshalTo(dAtA []byte) (int, error)

func (*Schedulability_Tenancy) ProtoMessage 

func (*Schedulability_Tenancy) ProtoMessage()

func (*Schedulability_Tenancy) Reset 

func (m *Schedulability_Tenancy) Reset()

func (*Schedulability_Tenancy) Size 

func (m *Schedulability_Tenancy) Size() (n int)

func (*Schedulability_Tenancy) String 

func (m *Schedulability_Tenancy) String() string

func (*Schedulability_Tenancy) Unmarshal 

func (m *Schedulability_Tenancy) Unmarshal(dAtA []byte) error

func (*Schedulability_Tenancy) XXX_DiscardUnknown 

func (m *Schedulability_Tenancy) XXX_DiscardUnknown()

func (*Schedulability_Tenancy) XXX_Marshal 

func (m *Schedulability_Tenancy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schedulability_Tenancy) XXX_Merge 

func (m *Schedulability_Tenancy) XXX_Merge(src proto.Message)

func (*Schedulability_Tenancy) XXX_Size 

func (m *Schedulability_Tenancy) XXX_Size() int

func (*Schedulability_Tenancy) XXX_Unmarshal 

func (m *Schedulability_Tenancy) XXX_Unmarshal(b []byte) error

type Schedulability_Tenancy_Durability 

type Schedulability_Tenancy_Durability struct {
	Low                  []NetworkType `` /* 130-byte string literal not displayed */
	High                 []NetworkType `` /* 134-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Schedulability_Tenancy_Durability) Descriptor 

func (*Schedulability_Tenancy_Durability) Descriptor() ([]byte, []int)

func (*Schedulability_Tenancy_Durability) GetHigh 

func (m *Schedulability_Tenancy_Durability) GetHigh() []NetworkType

func (*Schedulability_Tenancy_Durability) GetLow 

func (m *Schedulability_Tenancy_Durability) GetLow() []NetworkType

func (*Schedulability_Tenancy_Durability) Marshal 

func (m *Schedulability_Tenancy_Durability) Marshal() (dAtA []byte, err error)

func (*Schedulability_Tenancy_Durability) MarshalTo 

func (m *Schedulability_Tenancy_Durability) MarshalTo(dAtA []byte) (int, error)

func (*Schedulability_Tenancy_Durability) ProtoMessage 

func (*Schedulability_Tenancy_Durability) ProtoMessage()

func (*Schedulability_Tenancy_Durability) Reset 

func (m *Schedulability_Tenancy_Durability) Reset()

func (*Schedulability_Tenancy_Durability) Size 

func (m *Schedulability_Tenancy_Durability) Size() (n int)

func (*Schedulability_Tenancy_Durability) String 

func (m *Schedulability_Tenancy_Durability) String() string

func (*Schedulability_Tenancy_Durability) Unmarshal 

func (m *Schedulability_Tenancy_Durability) Unmarshal(dAtA []byte) error

func (*Schedulability_Tenancy_Durability) XXX_DiscardUnknown 

func (m *Schedulability_Tenancy_Durability) XXX_DiscardUnknown()

func (*Schedulability_Tenancy_Durability) XXX_Marshal 

func (m *Schedulability_Tenancy_Durability) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schedulability_Tenancy_Durability) XXX_Merge 

func (m *Schedulability_Tenancy_Durability) XXX_Merge(src proto.Message)

func (*Schedulability_Tenancy_Durability) XXX_Size 

func (m *Schedulability_Tenancy_Durability) XXX_Size() int

func (*Schedulability_Tenancy_Durability) XXX_Unmarshal 

func (m *Schedulability_Tenancy_Durability) XXX_Unmarshal(b []byte) error

type SchemaRegistry 

type SchemaRegistry interface {
	CreateSchemaRegistryCluster(*SchemaRegistryClusterConfig) (*SchemaRegistryCluster, error)
	GetSchemaRegistryClusters(*SchemaRegistryCluster) ([]*SchemaRegistryCluster, error)
	GetSchemaRegistryCluster(*SchemaRegistryCluster) (*SchemaRegistryCluster, error)
	UpdateSchemaRegistryCluster(*SchemaRegistryCluster) (*SchemaRegistryCluster, error)
	DeleteSchemaRegistryCluster(*SchemaRegistryCluster) error
}

Schema Registry service allows managing SR clusters in Confluent Cloud

type SchemaRegistryCluster 

type SchemaRegistryCluster struct {
	Id                string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	Name              string           `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"`
	KafkaClusterId    string           `` /* 170-byte string literal not displayed */
	Endpoint          string           `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty" db:"endpoint,omitempty" url:"endpoint,omitempty"`
	Created           *types.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified          *types.Timestamp `protobuf:"bytes,5,opt,name=modified,proto3" json:"modified,omitempty" db:"modified,omitempty" url:"modified,omitempty"`
	Status            ClusterStatus    `` /* 147-byte string literal not displayed */
	PhysicalClusterId string           `` /* 185-byte string literal not displayed */
	AccountId         string           `` /* 131-byte string literal not displayed */
	OrganizationId    int32            `` /* 167-byte string literal not displayed */
	// maximum number of schemas allowed for this logical cluster
	MaxSchemas            int32                   `` /* 148-byte string literal not displayed */
	OrgResourceId         string                  `` /* 166-byte string literal not displayed */
	Package               string                  `protobuf:"bytes,13,opt,name=package,proto3" json:"package,omitempty" db:"package,omitempty" url:"package,omitempty"`
	ServiceProvider       string                  `` /* 172-byte string literal not displayed */
	ServiceProviderRegion string                  `` /* 206-byte string literal not displayed */
	Region                *StreamGovernanceRegion `protobuf:"bytes,19,opt,name=region,proto3" json:"region,omitempty" db:"region,omitempty" url:"region,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                `json:"-"`
	XXX_unrecognized      []byte                  `json:"-"`
	XXX_sizecache         int32                   `json:"-"`
}

func (*SchemaRegistryCluster) Descriptor 

func (*SchemaRegistryCluster) Descriptor() ([]byte, []int)

func (*SchemaRegistryCluster) GetAccountId 

func (m *SchemaRegistryCluster) GetAccountId() string

func (*SchemaRegistryCluster) GetCreated 

func (m *SchemaRegistryCluster) GetCreated() *types.Timestamp

func (*SchemaRegistryCluster) GetEndpoint 

func (m *SchemaRegistryCluster) GetEndpoint() string

func (*SchemaRegistryCluster) GetId 

func (m *SchemaRegistryCluster) GetId() string

func (*SchemaRegistryCluster) GetKafkaClusterId 

func (m *SchemaRegistryCluster) GetKafkaClusterId() string

func (*SchemaRegistryCluster) GetMaxSchemas 

func (m *SchemaRegistryCluster) GetMaxSchemas() int32

func (*SchemaRegistryCluster) GetModified 

func (m *SchemaRegistryCluster) GetModified() *types.Timestamp

func (*SchemaRegistryCluster) GetName 

func (m *SchemaRegistryCluster) GetName() string

func (*SchemaRegistryCluster) GetOrgResourceId 

func (m *SchemaRegistryCluster) GetOrgResourceId() string

func (*SchemaRegistryCluster) GetOrganizationId 

func (m *SchemaRegistryCluster) GetOrganizationId() int32

func (*SchemaRegistryCluster) GetPackage 

func (m *SchemaRegistryCluster) GetPackage() string

func (*SchemaRegistryCluster) GetPhysicalClusterId 

func (m *SchemaRegistryCluster) GetPhysicalClusterId() string

func (*SchemaRegistryCluster) GetRegion 

func (m *SchemaRegistryCluster) GetRegion() *StreamGovernanceRegion

func (*SchemaRegistryCluster) GetServiceProvider 

func (m *SchemaRegistryCluster) GetServiceProvider() string

func (*SchemaRegistryCluster) GetServiceProviderRegion 

func (m *SchemaRegistryCluster) GetServiceProviderRegion() string

func (*SchemaRegistryCluster) GetStatus 

func (m *SchemaRegistryCluster) GetStatus() ClusterStatus

func (*SchemaRegistryCluster) Marshal 

func (m *SchemaRegistryCluster) Marshal() (dAtA []byte, err error)

func (*SchemaRegistryCluster) MarshalTo 

func (m *SchemaRegistryCluster) MarshalTo(dAtA []byte) (int, error)

func (*SchemaRegistryCluster) ProtoMessage 

func (*SchemaRegistryCluster) ProtoMessage()

func (*SchemaRegistryCluster) Reset 

func (m *SchemaRegistryCluster) Reset()

func (*SchemaRegistryCluster) Size 

func (m *SchemaRegistryCluster) Size() (n int)

func (*SchemaRegistryCluster) String 

func (m *SchemaRegistryCluster) String() string

func (*SchemaRegistryCluster) Unmarshal 

func (m *SchemaRegistryCluster) Unmarshal(dAtA []byte) error

func (*SchemaRegistryCluster) XXX_DiscardUnknown 

func (m *SchemaRegistryCluster) XXX_DiscardUnknown()

func (*SchemaRegistryCluster) XXX_Marshal 

func (m *SchemaRegistryCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaRegistryCluster) XXX_Merge 

func (m *SchemaRegistryCluster) XXX_Merge(src proto.Message)

func (*SchemaRegistryCluster) XXX_Size 

func (m *SchemaRegistryCluster) XXX_Size() int

func (*SchemaRegistryCluster) XXX_Unmarshal 

func (m *SchemaRegistryCluster) XXX_Unmarshal(b []byte) error

type SchemaRegistryClusterConfig 

type SchemaRegistryClusterConfig struct {
	Name           string                       `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"` // Deprecated: Do not use.
	KafkaClusterId string                       ``                                                                                                       /* 170-byte string literal not displayed */
	Servers        int32                        `protobuf:"varint,2,opt,name=servers,proto3" json:"servers,omitempty" db:"servers,omitempty" url:"servers,omitempty"`
	AccountId      string                       `` /* 141-byte string literal not displayed */
	Location       GlobalSchemaRegistryLocation `` // Deprecated: Do not use.
	/* 170-byte string literal not displayed */
	ServiceProvider       string                  `` /* 171-byte string literal not displayed */
	PhysicalClusterId     string                  `` /* 185-byte string literal not displayed */
	Package               string                  `protobuf:"bytes,8,opt,name=package,proto3" json:"package,omitempty" db:"package,omitempty" url:"package,omitempty"`
	ServiceProviderRegion string                  `` /* 205-byte string literal not displayed */
	Region                *StreamGovernanceRegion `protobuf:"bytes,10,opt,name=region,proto3" json:"region,omitempty" db:"region,omitempty" url:"region,omitempty"`
	Dedicated             bool                    `protobuf:"varint,11,opt,name=dedicated,proto3" json:"dedicated,omitempty" db:"dedicated,omitempty" url:"dedicated,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}                `json:"-"`
	XXX_unrecognized      []byte                  `json:"-"`
	XXX_sizecache         int32                   `json:"-"`
}

func (*SchemaRegistryClusterConfig) Descriptor 

func (*SchemaRegistryClusterConfig) Descriptor() ([]byte, []int)

func (*SchemaRegistryClusterConfig) GetAccountId 

func (m *SchemaRegistryClusterConfig) GetAccountId() string

func (*SchemaRegistryClusterConfig) GetDedicated 

func (m *SchemaRegistryClusterConfig) GetDedicated() bool

func (*SchemaRegistryClusterConfig) GetKafkaClusterId 

func (m *SchemaRegistryClusterConfig) GetKafkaClusterId() string

func (*SchemaRegistryClusterConfig) GetLocation deprecated 

func (m *SchemaRegistryClusterConfig) GetLocation() GlobalSchemaRegistryLocation

Deprecated: Do not use.

func (*SchemaRegistryClusterConfig) GetName deprecated 

func (m *SchemaRegistryClusterConfig) GetName() string

Deprecated: Do not use.

func (*SchemaRegistryClusterConfig) GetPackage 

func (m *SchemaRegistryClusterConfig) GetPackage() string

func (*SchemaRegistryClusterConfig) GetPhysicalClusterId 

func (m *SchemaRegistryClusterConfig) GetPhysicalClusterId() string

func (*SchemaRegistryClusterConfig) GetRegion 

func (m *SchemaRegistryClusterConfig) GetRegion() *StreamGovernanceRegion

func (*SchemaRegistryClusterConfig) GetServers 

func (m *SchemaRegistryClusterConfig) GetServers() int32

func (*SchemaRegistryClusterConfig) GetServiceProvider 

func (m *SchemaRegistryClusterConfig) GetServiceProvider() string

func (*SchemaRegistryClusterConfig) GetServiceProviderRegion 

func (m *SchemaRegistryClusterConfig) GetServiceProviderRegion() string

func (*SchemaRegistryClusterConfig) Marshal 

func (m *SchemaRegistryClusterConfig) Marshal() (dAtA []byte, err error)

func (*SchemaRegistryClusterConfig) MarshalTo 

func (m *SchemaRegistryClusterConfig) MarshalTo(dAtA []byte) (int, error)

func (*SchemaRegistryClusterConfig) ProtoMessage 

func (*SchemaRegistryClusterConfig) ProtoMessage()

func (*SchemaRegistryClusterConfig) Reset 

func (m *SchemaRegistryClusterConfig) Reset()

func (*SchemaRegistryClusterConfig) Size 

func (m *SchemaRegistryClusterConfig) Size() (n int)

func (*SchemaRegistryClusterConfig) String 

func (m *SchemaRegistryClusterConfig) String() string

func (*SchemaRegistryClusterConfig) Unmarshal 

func (m *SchemaRegistryClusterConfig) Unmarshal(dAtA []byte) error

func (*SchemaRegistryClusterConfig) XXX_DiscardUnknown 

func (m *SchemaRegistryClusterConfig) XXX_DiscardUnknown()

func (*SchemaRegistryClusterConfig) XXX_Marshal 

func (m *SchemaRegistryClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaRegistryClusterConfig) XXX_Merge 

func (m *SchemaRegistryClusterConfig) XXX_Merge(src proto.Message)

func (*SchemaRegistryClusterConfig) XXX_Size 

func (m *SchemaRegistryClusterConfig) XXX_Size() int

func (*SchemaRegistryClusterConfig) XXX_Unmarshal 

func (m *SchemaRegistryClusterConfig) XXX_Unmarshal(b []byte) error

type SchemaRegistryLocation 

type SchemaRegistryLocation struct {
	Id GlobalSchemaRegistryLocation `` // Deprecated: Do not use.
	/* 146-byte string literal not displayed */
	Name                  string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" db:"name,omitempty" url:"name,omitempty"` // Deprecated: Do not use.
	ClusterId             string   ``                                                                                                       /* 141-byte string literal not displayed */
	ServiceProvider       string   ``                                                                                                       /* 171-byte string literal not displayed */
	Package               []string `protobuf:"bytes,5,rep,name=package,proto3" json:"package,omitempty" db:"package,omitempty" url:"package,omitempty"`
	ServiceProviderRegion string   `` /* 205-byte string literal not displayed */
	RegionDisplayName     string   `` /* 185-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*SchemaRegistryLocation) Descriptor 

func (*SchemaRegistryLocation) Descriptor() ([]byte, []int)

func (*SchemaRegistryLocation) GetClusterId 

func (m *SchemaRegistryLocation) GetClusterId() string

func (*SchemaRegistryLocation) GetId deprecated 

func (m *SchemaRegistryLocation) GetId() GlobalSchemaRegistryLocation

Deprecated: Do not use.

func (*SchemaRegistryLocation) GetName deprecated 

func (m *SchemaRegistryLocation) GetName() string

Deprecated: Do not use.

func (*SchemaRegistryLocation) GetPackage 

func (m *SchemaRegistryLocation) GetPackage() []string

func (*SchemaRegistryLocation) GetRegionDisplayName 

func (m *SchemaRegistryLocation) GetRegionDisplayName() string

func (*SchemaRegistryLocation) GetServiceProvider 

func (m *SchemaRegistryLocation) GetServiceProvider() string

func (*SchemaRegistryLocation) GetServiceProviderRegion 

func (m *SchemaRegistryLocation) GetServiceProviderRegion() string

func (*SchemaRegistryLocation) Marshal 

func (m *SchemaRegistryLocation) Marshal() (dAtA []byte, err error)

func (*SchemaRegistryLocation) MarshalTo 

func (m *SchemaRegistryLocation) MarshalTo(dAtA []byte) (int, error)

func (*SchemaRegistryLocation) ProtoMessage 

func (*SchemaRegistryLocation) ProtoMessage()

func (*SchemaRegistryLocation) Reset 

func (m *SchemaRegistryLocation) Reset()

func (*SchemaRegistryLocation) Size 

func (m *SchemaRegistryLocation) Size() (n int)

func (*SchemaRegistryLocation) String 

func (m *SchemaRegistryLocation) String() string

func (*SchemaRegistryLocation) Unmarshal 

func (m *SchemaRegistryLocation) Unmarshal(dAtA []byte) error

func (*SchemaRegistryLocation) XXX_DiscardUnknown 

func (m *SchemaRegistryLocation) XXX_DiscardUnknown()

func (*SchemaRegistryLocation) XXX_Marshal 

func (m *SchemaRegistryLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaRegistryLocation) XXX_Merge 

func (m *SchemaRegistryLocation) XXX_Merge(src proto.Message)

func (*SchemaRegistryLocation) XXX_Size 

func (m *SchemaRegistryLocation) XXX_Size() int

func (*SchemaRegistryLocation) XXX_Unmarshal 

func (m *SchemaRegistryLocation) XXX_Unmarshal(b []byte) error

type SchemaRegistryService 

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

SchemaRegistryService provides methods for creating and reading connectors

func NewSchemaRegistryService 

func NewSchemaRegistryService(client *Client) *SchemaRegistryService

NewSchemaRegistryService returns a new SchemaRegistryService.

func (*SchemaRegistryService) CreateSchemaRegistryCluster 

func (s *SchemaRegistryService) CreateSchemaRegistryCluster(config *SchemaRegistryClusterConfig) (*SchemaRegistryCluster, error)

func (*SchemaRegistryService) DeleteSchemaRegistryCluster 

func (s *SchemaRegistryService) DeleteSchemaRegistryCluster(cluster *SchemaRegistryCluster) error

func (*SchemaRegistryService) GetSchemaRegistryCluster 

func (s *SchemaRegistryService) GetSchemaRegistryCluster(cluster *SchemaRegistryCluster) (*SchemaRegistryCluster, error)

func (*SchemaRegistryService) GetSchemaRegistryClusters 

func (s *SchemaRegistryService) GetSchemaRegistryClusters(cluster *SchemaRegistryCluster) ([]*SchemaRegistryCluster, error)

func (*SchemaRegistryService) UpdateSchemaRegistryCluster 

func (s *SchemaRegistryService) UpdateSchemaRegistryCluster(cluster *SchemaRegistryCluster) (*SchemaRegistryCluster, error)

type Secret 

type Secret struct {
	// see APIKeysSecret, APIKeysDataKey in consts.go if you're using this for the API keys
	*v1.Secret           ``       /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Secret) Descriptor 

func (*Secret) Descriptor() ([]byte, []int)

func (*Secret) Marshal 

func (m *Secret) Marshal() (dAtA []byte, err error)

func (*Secret) MarshalTo 

func (m *Secret) MarshalTo(dAtA []byte) (int, error)

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) Reset 

func (m *Secret) Reset()

func (*Secret) Size 

func (m *Secret) Size() (n int)

func (*Secret) String 

func (m *Secret) String() string

func (*Secret) Unmarshal 

func (m *Secret) Unmarshal(dAtA []byte) error

func (*Secret) XXX_DiscardUnknown 

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal 

func (m *Secret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Secret) XXX_Merge 

func (m *Secret) XXX_Merge(src proto.Message)

func (*Secret) XXX_Size 

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal 

func (m *Secret) XXX_Unmarshal(b []byte) error

type Signup 

type Signup interface {
	Create(*SignupRequest) (*SignupReply, error)
	SendVerificationEmail(*User) error
}

Signup service allows managing signups in Confluent Cloud

type SignupReply 

type SignupReply struct {
	User                 *User         `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	Organization         *Organization `` /* 134-byte string literal not displayed */
	Account              *Account      `protobuf:"bytes,3,opt,name=account,proto3" json:"account,omitempty" db:"account,omitempty" url:"account,omitempty"`
	Error                *Error        `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SignupReply) Descriptor 

func (*SignupReply) Descriptor() ([]byte, []int)

func (*SignupReply) GetAccount 

func (m *SignupReply) GetAccount() *Account

func (*SignupReply) GetError 

func (m *SignupReply) GetError() *Error

func (*SignupReply) GetOrganization 

func (m *SignupReply) GetOrganization() *Organization

func (*SignupReply) GetUser 

func (m *SignupReply) GetUser() *User

func (*SignupReply) Marshal 

func (m *SignupReply) Marshal() (dAtA []byte, err error)

func (*SignupReply) MarshalTo 

func (m *SignupReply) MarshalTo(dAtA []byte) (int, error)

func (*SignupReply) ProtoMessage 

func (*SignupReply) ProtoMessage()

func (*SignupReply) Reset 

func (m *SignupReply) Reset()

func (*SignupReply) Size 

func (m *SignupReply) Size() (n int)

func (*SignupReply) String 

func (m *SignupReply) String() string

func (*SignupReply) Unmarshal 

func (m *SignupReply) Unmarshal(dAtA []byte) error

func (*SignupReply) XXX_DiscardUnknown 

func (m *SignupReply) XXX_DiscardUnknown()

func (*SignupReply) XXX_Marshal 

func (m *SignupReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignupReply) XXX_Merge 

func (m *SignupReply) XXX_Merge(src proto.Message)

func (*SignupReply) XXX_Size 

func (m *SignupReply) XXX_Size() int

func (*SignupReply) XXX_Unmarshal 

func (m *SignupReply) XXX_Unmarshal(b []byte) error

type SignupRequest 

type SignupRequest struct {
	Organization         *Organization     `` /* 134-byte string literal not displayed */
	User                 *User             `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty" db:"user,omitempty" url:"user,omitempty"`
	Credentials          *Credentials      `` /* 130-byte string literal not displayed */
	StripeToken          string            `` /* 151-byte string literal not displayed */
	Enterprise           bool              `` /* 127-byte string literal not displayed */
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	Utm                  *Utm              `protobuf:"bytes,7,opt,name=utm,proto3" json:"utm,omitempty" db:"utm,omitempty" url:"utm,omitempty"`
	ExistingCreds        bool              `` /* 162-byte string literal not displayed */
	Token                string            `protobuf:"bytes,9,opt,name=token,proto3" json:"token,omitempty" db:"token,omitempty" url:"token,omitempty"`
	MarketplaceCreds     *MarketplaceCreds `` /* 177-byte string literal not displayed */
	CountryCode          string            `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SignupRequest) Descriptor 

func (*SignupRequest) Descriptor() ([]byte, []int)

func (*SignupRequest) GetCountryCode 

func (m *SignupRequest) GetCountryCode() string

func (*SignupRequest) GetCredentials 

func (m *SignupRequest) GetCredentials() *Credentials

func (*SignupRequest) GetEnterprise 

func (m *SignupRequest) GetEnterprise() bool

func (*SignupRequest) GetExistingCreds 

func (m *SignupRequest) GetExistingCreds() bool

func (*SignupRequest) GetMarketplaceCreds 

func (m *SignupRequest) GetMarketplaceCreds() *MarketplaceCreds

func (*SignupRequest) GetOrganization 

func (m *SignupRequest) GetOrganization() *Organization

func (*SignupRequest) GetRequestCarrier 

func (m *SignupRequest) GetRequestCarrier() map[string]string

func (*SignupRequest) GetStripeToken 

func (m *SignupRequest) GetStripeToken() string

func (*SignupRequest) GetToken 

func (m *SignupRequest) GetToken() string

func (*SignupRequest) GetUser 

func (m *SignupRequest) GetUser() *User

func (*SignupRequest) GetUtm 

func (m *SignupRequest) GetUtm() *Utm

func (*SignupRequest) Marshal 

func (m *SignupRequest) Marshal() (dAtA []byte, err error)

func (*SignupRequest) MarshalTo 

func (m *SignupRequest) MarshalTo(dAtA []byte) (int, error)

func (*SignupRequest) ProtoMessage 

func (*SignupRequest) ProtoMessage()

func (*SignupRequest) Reset 

func (m *SignupRequest) Reset()

func (*SignupRequest) SetRequestCarrier 

func (t *SignupRequest) SetRequestCarrier(request_carrier map[string]string)

func (*SignupRequest) Size 

func (m *SignupRequest) Size() (n int)

func (*SignupRequest) String 

func (m *SignupRequest) String() string

func (*SignupRequest) Unmarshal 

func (m *SignupRequest) Unmarshal(dAtA []byte) error

func (*SignupRequest) XXX_DiscardUnknown 

func (m *SignupRequest) XXX_DiscardUnknown()

func (*SignupRequest) XXX_Marshal 

func (m *SignupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignupRequest) XXX_Merge 

func (m *SignupRequest) XXX_Merge(src proto.Message)

func (*SignupRequest) XXX_Size 

func (m *SignupRequest) XXX_Size() int

func (*SignupRequest) XXX_Unmarshal 

func (m *SignupRequest) XXX_Unmarshal(b []byte) error

type SignupService 

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

func NewSignupService 

func NewSignupService(client *Client) *SignupService

func (*SignupService) Create 

func (s *SignupService) Create(req *SignupRequest) (*SignupReply, error)

func (*SignupService) SendVerificationEmail 

func (s *SignupService) SendVerificationEmail(user *User) error

type Sku 

type Sku int32
const (
	Sku_UNKNOWN          Sku = 0
	Sku_BASIC_LEGACY     Sku = 1
	Sku_BASIC            Sku = 2
	Sku_STANDARD         Sku = 3
	Sku_DEDICATED        Sku = 4
	Sku_DEDICATED_LEGACY Sku = 5
	Sku_ENTERPRISE       Sku = 6
)

func (Sku) EnumDescriptor 

func (Sku) EnumDescriptor() ([]byte, []int)

func (Sku) String 

func (x Sku) String() string

type Sso 

type Sso struct {
	Enabled              bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty" db:"enabled,omitempty" url:"enabled,omitempty"`
	Auth0ConnectionName  string   `` /* 195-byte string literal not displayed */
	TenantId             string   `` /* 136-byte string literal not displayed */
	MultiTenant          bool     `` /* 152-byte string literal not displayed */
	Mode                 SsoMode  `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

representation of SSO configs on the DB records themselves

func (*Sso) Descriptor 

func (*Sso) Descriptor() ([]byte, []int)

func (*Sso) GetAuth0ConnectionName 

func (m *Sso) GetAuth0ConnectionName() string

func (*Sso) GetEnabled 

func (m *Sso) GetEnabled() bool

func (*Sso) GetMode 

func (m *Sso) GetMode() SsoMode

func (*Sso) GetMultiTenant 

func (m *Sso) GetMultiTenant() bool

func (*Sso) GetTenantId 

func (m *Sso) GetTenantId() string

func (*Sso) Marshal 

func (m *Sso) Marshal() (dAtA []byte, err error)

func (*Sso) MarshalTo 

func (m *Sso) MarshalTo(dAtA []byte) (int, error)

func (*Sso) ProtoMessage 

func (*Sso) ProtoMessage()

func (*Sso) Reset 

func (m *Sso) Reset()

func (*Sso) Scan 

func (t *Sso) Scan(val interface{}) error

func (*Sso) Size 

func (m *Sso) Size() (n int)

func (*Sso) String 

func (m *Sso) String() string

func (*Sso) Unmarshal 

func (m *Sso) Unmarshal(dAtA []byte) error

func (*Sso) Value 

func (t *Sso) Value() (driver.Value, error)

func (*Sso) XXX_DiscardUnknown 

func (m *Sso) XXX_DiscardUnknown()

func (*Sso) XXX_Marshal 

func (m *Sso) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sso) XXX_Merge 

func (m *Sso) XXX_Merge(src proto.Message)

func (*Sso) XXX_Size 

func (m *Sso) XXX_Size() int

func (*Sso) XXX_Unmarshal 

func (m *Sso) XXX_Unmarshal(b []byte) error

type SsoMode 

type SsoMode int32
const (
	SsoMode_SSO_MODE_UNKNOWN    SsoMode = 0
	SsoMode_SSO_MODE_RESTRICTED SsoMode = 1
	SsoMode_SSO_MODE_LAX        SsoMode = 2
)

func (SsoMode) EnumDescriptor 

func (SsoMode) EnumDescriptor() ([]byte, []int)

func (SsoMode) String 

func (x SsoMode) String() string

type Stack 

type Stack struct {
	Callers []uintptr
}

func (*Stack) MarshalTo 

func (t *Stack) MarshalTo(data []byte) (n int, err error)

func (*Stack) Size 

func (t *Stack) Size() int

func (*Stack) Unmarshal 

func (t *Stack) Unmarshal(data []byte) error

type StreamGovernanceRegion 

type StreamGovernanceRegion struct {
	Created              *types.Timestamp               `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified             *types.Timestamp               `protobuf:"bytes,2,opt,name=modified,proto3" json:"modified,omitempty" db:"modified,omitempty" url:"modified,omitempty"`
	Deactivated          *types.Timestamp               `` /* 130-byte string literal not displayed */
	Id                   string                         `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty" db:"id,omitempty" url:"id,omitempty"`
	DisplayName          string                         `` /* 151-byte string literal not displayed */
	Cloud                string                         `protobuf:"bytes,6,opt,name=cloud,proto3" json:"cloud,omitempty" db:"cloud,omitempty" url:"cloud,omitempty"`
	RegionId             string                         `` /* 136-byte string literal not displayed */
	EnvironmentId        string                         `` /* 161-byte string literal not displayed */
	Config               *StreamGovernanceRegion_Config `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty" db:"config,omitempty" url:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*StreamGovernanceRegion) Descriptor 

func (*StreamGovernanceRegion) Descriptor() ([]byte, []int)

func (*StreamGovernanceRegion) GetCloud 

func (m *StreamGovernanceRegion) GetCloud() string

func (*StreamGovernanceRegion) GetConfig 

func (m *StreamGovernanceRegion) GetConfig() *StreamGovernanceRegion_Config

func (*StreamGovernanceRegion) GetCreated 

func (m *StreamGovernanceRegion) GetCreated() *types.Timestamp

func (*StreamGovernanceRegion) GetDeactivated 

func (m *StreamGovernanceRegion) GetDeactivated() *types.Timestamp

func (*StreamGovernanceRegion) GetDisplayName 

func (m *StreamGovernanceRegion) GetDisplayName() string

func (*StreamGovernanceRegion) GetEnvironmentId 

func (m *StreamGovernanceRegion) GetEnvironmentId() string

func (*StreamGovernanceRegion) GetId 

func (m *StreamGovernanceRegion) GetId() string

func (*StreamGovernanceRegion) GetModified 

func (m *StreamGovernanceRegion) GetModified() *types.Timestamp

func (*StreamGovernanceRegion) GetRegionId 

func (m *StreamGovernanceRegion) GetRegionId() string

func (*StreamGovernanceRegion) Marshal 

func (m *StreamGovernanceRegion) Marshal() (dAtA []byte, err error)

func (*StreamGovernanceRegion) MarshalTo 

func (m *StreamGovernanceRegion) MarshalTo(dAtA []byte) (int, error)

func (*StreamGovernanceRegion) ProtoMessage 

func (*StreamGovernanceRegion) ProtoMessage()

func (*StreamGovernanceRegion) Reset 

func (m *StreamGovernanceRegion) Reset()

func (*StreamGovernanceRegion) Size 

func (m *StreamGovernanceRegion) Size() (n int)

func (*StreamGovernanceRegion) String 

func (m *StreamGovernanceRegion) String() string

func (*StreamGovernanceRegion) Unmarshal 

func (m *StreamGovernanceRegion) Unmarshal(dAtA []byte) error

func (*StreamGovernanceRegion) XXX_DiscardUnknown 

func (m *StreamGovernanceRegion) XXX_DiscardUnknown()

func (*StreamGovernanceRegion) XXX_Marshal 

func (m *StreamGovernanceRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamGovernanceRegion) XXX_Merge 

func (m *StreamGovernanceRegion) XXX_Merge(src proto.Message)

func (*StreamGovernanceRegion) XXX_Size 

func (m *StreamGovernanceRegion) XXX_Size() int

func (*StreamGovernanceRegion) XXX_Unmarshal 

func (m *StreamGovernanceRegion) XXX_Unmarshal(b []byte) error

type StreamGovernanceRegion_Config 

type StreamGovernanceRegion_Config struct {
	ClusterId       string   `` /* 141-byte string literal not displayed */
	Package         []string `protobuf:"bytes,2,rep,name=package,proto3" json:"package,omitempty" db:"package,omitempty" url:"package,omitempty"`
	GeolocationName string   `` // Deprecated: Do not use.
	/* 171-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamGovernanceRegion_Config) Descriptor 

func (*StreamGovernanceRegion_Config) Descriptor() ([]byte, []int)

func (*StreamGovernanceRegion_Config) GetClusterId 

func (m *StreamGovernanceRegion_Config) GetClusterId() string

func (*StreamGovernanceRegion_Config) GetGeolocationName deprecated 

func (m *StreamGovernanceRegion_Config) GetGeolocationName() string

Deprecated: Do not use.

func (*StreamGovernanceRegion_Config) GetPackage 

func (m *StreamGovernanceRegion_Config) GetPackage() []string

func (*StreamGovernanceRegion_Config) Marshal 

func (m *StreamGovernanceRegion_Config) Marshal() (dAtA []byte, err error)

func (*StreamGovernanceRegion_Config) MarshalTo 

func (m *StreamGovernanceRegion_Config) MarshalTo(dAtA []byte) (int, error)

func (*StreamGovernanceRegion_Config) ProtoMessage 

func (*StreamGovernanceRegion_Config) ProtoMessage()

func (*StreamGovernanceRegion_Config) Reset 

func (m *StreamGovernanceRegion_Config) Reset()

func (*StreamGovernanceRegion_Config) Scan 

func (t *StreamGovernanceRegion_Config) Scan(val interface{}) error

func (*StreamGovernanceRegion_Config) Size 

func (m *StreamGovernanceRegion_Config) Size() (n int)

func (*StreamGovernanceRegion_Config) String 

func (m *StreamGovernanceRegion_Config) String() string

func (*StreamGovernanceRegion_Config) Unmarshal 

func (m *StreamGovernanceRegion_Config) Unmarshal(dAtA []byte) error

func (*StreamGovernanceRegion_Config) Value 

func (t *StreamGovernanceRegion_Config) Value() (driver.Value, error)

func (*StreamGovernanceRegion_Config) XXX_DiscardUnknown 

func (m *StreamGovernanceRegion_Config) XXX_DiscardUnknown()

func (*StreamGovernanceRegion_Config) XXX_Marshal 

func (m *StreamGovernanceRegion_Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamGovernanceRegion_Config) XXX_Merge 

func (m *StreamGovernanceRegion_Config) XXX_Merge(src proto.Message)

func (*StreamGovernanceRegion_Config) XXX_Size 

func (m *StreamGovernanceRegion_Config) XXX_Size() int

func (*StreamGovernanceRegion_Config) XXX_Unmarshal 

func (m *StreamGovernanceRegion_Config) XXX_Unmarshal(b []byte) error

type SuspendedOrganizationError 

type SuspendedOrganizationError struct{}

func (*SuspendedOrganizationError) Error 

func (e *SuspendedOrganizationError) Error() string

type SuspensionEventType 

type SuspensionEventType int32
const (
	SuspensionEventType_SUSPENSION_EVENT_UNKNOWN                              SuspensionEventType = 0
	SuspensionEventType_SUSPENSION_EVENT_END_OF_FREE_TRIAL                    SuspensionEventType = 1
	SuspensionEventType_SUSPENSION_EVENT_CUSTOMER_INITIATED_ORG_DEACTIVATION  SuspensionEventType = 2
	SuspensionEventType_SUSPENSION_EVENT_MARKETPLACE_ENTITLEMENT_CANCELLATION SuspensionEventType = 3
	SuspensionEventType_SUSPENSION_EVENT_NO_PAYMENT                           SuspensionEventType = 4
	SuspensionEventType_SUSPENSION_EVENT_SECURITY_INCIDENT_OR_ABUSE           SuspensionEventType = 5
	SuspensionEventType_SUSPENSION_EVENT_OTHERS                               SuspensionEventType = 6
	SuspensionEventType_SUSPENSION_EVENT_INTERNAL_INITIATED_ORG_DEACTIVATION  SuspensionEventType = 7
)

func (SuspensionEventType) EnumDescriptor 

func (SuspensionEventType) EnumDescriptor() ([]byte, []int)

func (SuspensionEventType) String 

func (x SuspensionEventType) String() string

type SuspensionStatus 

type SuspensionStatus struct {
	Suspended                   *types.Timestamp     `protobuf:"bytes,1,opt,name=suspended,proto3" json:"suspended,omitempty" db:"suspended,omitempty" url:"suspended,omitempty"`
	Status                      SuspensionStatusType `` /* 148-byte string literal not displayed */
	EventType                   SuspensionEventType  `` /* 178-byte string literal not displayed */
	ScheduledDeactivatedAt      *types.Timestamp     `` /* 210-byte string literal not displayed */
	Version                     int64                `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty" db:"version,omitempty" url:"version,omitempty"`
	ErrorMessage                string               `` /* 156-byte string literal not displayed */
	ScheduledResourcesDeletedAt *types.Timestamp     `` /* 239-byte string literal not displayed */
	ResourcesDeletedAt          *types.Timestamp     `` /* 190-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{}             `json:"-"`
	XXX_unrecognized            []byte               `json:"-"`
	XXX_sizecache               int32                `json:"-"`
}

func (*SuspensionStatus) Descriptor 

func (*SuspensionStatus) Descriptor() ([]byte, []int)

func (*SuspensionStatus) GetErrorMessage 

func (m *SuspensionStatus) GetErrorMessage() string

func (*SuspensionStatus) GetEventType 

func (m *SuspensionStatus) GetEventType() SuspensionEventType

func (*SuspensionStatus) GetResourcesDeletedAt 

func (m *SuspensionStatus) GetResourcesDeletedAt() *types.Timestamp

func (*SuspensionStatus) GetScheduledDeactivatedAt 

func (m *SuspensionStatus) GetScheduledDeactivatedAt() *types.Timestamp

func (*SuspensionStatus) GetScheduledResourcesDeletedAt 

func (m *SuspensionStatus) GetScheduledResourcesDeletedAt() *types.Timestamp

func (*SuspensionStatus) GetStatus 

func (m *SuspensionStatus) GetStatus() SuspensionStatusType

func (*SuspensionStatus) GetSuspended 

func (m *SuspensionStatus) GetSuspended() *types.Timestamp

func (*SuspensionStatus) GetVersion 

func (m *SuspensionStatus) GetVersion() int64

func (*SuspensionStatus) Marshal 

func (m *SuspensionStatus) Marshal() (dAtA []byte, err error)

func (*SuspensionStatus) MarshalTo 

func (m *SuspensionStatus) MarshalTo(dAtA []byte) (int, error)

func (*SuspensionStatus) ProtoMessage 

func (*SuspensionStatus) ProtoMessage()

func (*SuspensionStatus) Reset 

func (m *SuspensionStatus) Reset()

func (*SuspensionStatus) Size 

func (m *SuspensionStatus) Size() (n int)

func (*SuspensionStatus) String 

func (m *SuspensionStatus) String() string

func (*SuspensionStatus) Unmarshal 

func (m *SuspensionStatus) Unmarshal(dAtA []byte) error

func (*SuspensionStatus) XXX_DiscardUnknown 

func (m *SuspensionStatus) XXX_DiscardUnknown()

func (*SuspensionStatus) XXX_Marshal 

func (m *SuspensionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SuspensionStatus) XXX_Merge 

func (m *SuspensionStatus) XXX_Merge(src proto.Message)

func (*SuspensionStatus) XXX_Size 

func (m *SuspensionStatus) XXX_Size() int

func (*SuspensionStatus) XXX_Unmarshal 

func (m *SuspensionStatus) XXX_Unmarshal(b []byte) error

type SuspensionStatusType 

type SuspensionStatusType int32
const (
	SuspensionStatusType_SUSPENSION_UNKNOWN       SuspensionStatusType = 0
	SuspensionStatusType_SUSPENSION_IN_PROGRESS   SuspensionStatusType = 1
	SuspensionStatusType_SUSPENSION_COMPLETED     SuspensionStatusType = 2
	SuspensionStatusType_UNSUSPENSION_IN_PROGRESS SuspensionStatusType = 3
	SuspensionStatusType_SUSPENSION_FAILED        SuspensionStatusType = 4
	SuspensionStatusType_UNSUSPENSION_FAILED      SuspensionStatusType = 5
)

func (SuspensionStatusType) EnumDescriptor 

func (SuspensionStatusType) EnumDescriptor() ([]byte, []int)

func (SuspensionStatusType) String 

func (x SuspensionStatusType) String() string

type TaxAddress 

type TaxAddress struct {
	Line1 string `protobuf:"bytes,1,opt,name=line1,proto3" json:"line1,omitempty" db:"line1,omitempty" url:"line1,omitempty"`
	Line2 string `protobuf:"bytes,2,opt,name=line2,proto3" json:"line2,omitempty" db:"line2,omitempty" url:"line2,omitempty"`
	City  string `protobuf:"bytes,3,opt,name=city,proto3" json:"city,omitempty" db:"city,omitempty" url:"city,omitempty"`
	State string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty" db:"state,omitempty" url:"state,omitempty"`
	// country must follow the ISO 3166-1 alpha-2 standard
	// https://en.wikipedia.org/wiki/ISO_3166-1_alpha-2
	Country              string   `protobuf:"bytes,5,opt,name=country,proto3" json:"country,omitempty" db:"country,omitempty" url:"country,omitempty"`
	PostalCode           string   `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaxAddress) Descriptor 

func (*TaxAddress) Descriptor() ([]byte, []int)

func (*TaxAddress) GetCity 

func (m *TaxAddress) GetCity() string

func (*TaxAddress) GetCountry 

func (m *TaxAddress) GetCountry() string

func (*TaxAddress) GetLine1 

func (m *TaxAddress) GetLine1() string

func (*TaxAddress) GetLine2 

func (m *TaxAddress) GetLine2() string

func (*TaxAddress) GetPostalCode 

func (m *TaxAddress) GetPostalCode() string

func (*TaxAddress) GetState 

func (m *TaxAddress) GetState() string

func (*TaxAddress) Marshal 

func (m *TaxAddress) Marshal() (dAtA []byte, err error)

func (*TaxAddress) MarshalTo 

func (m *TaxAddress) MarshalTo(dAtA []byte) (int, error)

func (*TaxAddress) ProtoMessage 

func (*TaxAddress) ProtoMessage()

func (*TaxAddress) Reset 

func (m *TaxAddress) Reset()

func (*TaxAddress) Size 

func (m *TaxAddress) Size() (n int)

func (*TaxAddress) String 

func (m *TaxAddress) String() string

func (*TaxAddress) Unmarshal 

func (m *TaxAddress) Unmarshal(dAtA []byte) error

func (*TaxAddress) XXX_DiscardUnknown 

func (m *TaxAddress) XXX_DiscardUnknown()

func (*TaxAddress) XXX_Marshal 

func (m *TaxAddress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaxAddress) XXX_Merge 

func (m *TaxAddress) XXX_Merge(src proto.Message)

func (*TaxAddress) XXX_Size 

func (m *TaxAddress) XXX_Size() int

func (*TaxAddress) XXX_Unmarshal 

func (m *TaxAddress) XXX_Unmarshal(b []byte) error

type TaxId 

type TaxId struct {
	// details of taxId definition is here:
	// https://stripe.com/docs/api/customer_tax_ids/object
	TypeEnum             string   `` /* 136-byte string literal not displayed */
	TaxId                string   `protobuf:"bytes,2,opt,name=tax_id,json=taxId,proto3" json:"tax_id,omitempty" db:"tax_id,omitempty" url:"tax_id,omitempty"`
	StripeObjectId       string   `` /* 181-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaxId) Descriptor 

func (*TaxId) Descriptor() ([]byte, []int)

func (*TaxId) GetStripeObjectId 

func (m *TaxId) GetStripeObjectId() string

func (*TaxId) GetTaxId 

func (m *TaxId) GetTaxId() string

func (*TaxId) GetTypeEnum 

func (m *TaxId) GetTypeEnum() string

func (*TaxId) Marshal 

func (m *TaxId) Marshal() (dAtA []byte, err error)

func (*TaxId) MarshalTo 

func (m *TaxId) MarshalTo(dAtA []byte) (int, error)

func (*TaxId) ProtoMessage 

func (*TaxId) ProtoMessage()

func (*TaxId) Reset 

func (m *TaxId) Reset()

func (*TaxId) Size 

func (m *TaxId) Size() (n int)

func (*TaxId) String 

func (m *TaxId) String() string

func (*TaxId) Unmarshal 

func (m *TaxId) Unmarshal(dAtA []byte) error

func (*TaxId) XXX_DiscardUnknown 

func (m *TaxId) XXX_DiscardUnknown()

func (*TaxId) XXX_Marshal 

func (m *TaxId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaxId) XXX_Merge 

func (m *TaxId) XXX_Merge(src proto.Message)

func (*TaxId) XXX_Size 

func (m *TaxId) XXX_Size() int

func (*TaxId) XXX_Unmarshal 

func (m *TaxId) XXX_Unmarshal(b []byte) error

type TieredStorage 

type TieredStorage struct {
	Backend         string            `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty" db:"backend,omitempty" url:"backend,omitempty"`
	Bucket          string            `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty" db:"bucket,omitempty" url:"bucket,omitempty"`
	Region          string            `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty" db:"region,omitempty" url:"region,omitempty"`
	TierAllTopics   bool              `` /* 166-byte string literal not displayed */
	Role            string            `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty" db:"role,omitempty" url:"role,omitempty"`
	EncryptionKeyId string            `` /* 175-byte string literal not displayed */
	LocalHotsetMs   *types.Int64Value `` /* 165-byte string literal not displayed */
	Endpoint        string            `protobuf:"bytes,8,opt,name=endpoint,proto3" json:"endpoint,omitempty" db:"endpoint,omitempty" url:"endpoint,omitempty"`
	// e.g. credentials JSON, for example the REST API/clients format:
	// https://cloud.google.com/iam/docs/creating-managing-service-account-keys#creating_service_account_keys
	ServiceAccountSecret []byte `` /* 212-byte string literal not displayed */
	// e.g. the service account email in gcp
	ServiceAccountId string `` /* 181-byte string literal not displayed */
	// cire-storage-bucket-service deployment reference
	DeploymentId         string   `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TieredStorage) Descriptor 

func (*TieredStorage) Descriptor() ([]byte, []int)

func (*TieredStorage) GetBackend 

func (m *TieredStorage) GetBackend() string

func (*TieredStorage) GetBucket 

func (m *TieredStorage) GetBucket() string

func (*TieredStorage) GetDeploymentId 

func (m *TieredStorage) GetDeploymentId() string

func (*TieredStorage) GetEncryptionKeyId 

func (m *TieredStorage) GetEncryptionKeyId() string

func (*TieredStorage) GetEndpoint 

func (m *TieredStorage) GetEndpoint() string

func (*TieredStorage) GetLocalHotsetMs 

func (m *TieredStorage) GetLocalHotsetMs() *types.Int64Value

func (*TieredStorage) GetRegion 

func (m *TieredStorage) GetRegion() string

func (*TieredStorage) GetRole 

func (m *TieredStorage) GetRole() string

func (*TieredStorage) GetServiceAccountId 

func (m *TieredStorage) GetServiceAccountId() string

func (*TieredStorage) GetServiceAccountSecret 

func (m *TieredStorage) GetServiceAccountSecret() []byte

func (*TieredStorage) GetTierAllTopics 

func (m *TieredStorage) GetTierAllTopics() bool

func (*TieredStorage) Marshal 

func (m *TieredStorage) Marshal() (dAtA []byte, err error)

func (*TieredStorage) MarshalTo 

func (m *TieredStorage) MarshalTo(dAtA []byte) (int, error)

func (*TieredStorage) ProtoMessage 

func (*TieredStorage) ProtoMessage()

func (*TieredStorage) Reset 

func (m *TieredStorage) Reset()

func (*TieredStorage) Size 

func (m *TieredStorage) Size() (n int)

func (*TieredStorage) String 

func (m *TieredStorage) String() string

func (*TieredStorage) Unmarshal 

func (m *TieredStorage) Unmarshal(dAtA []byte) error

func (*TieredStorage) XXX_DiscardUnknown 

func (m *TieredStorage) XXX_DiscardUnknown()

func (*TieredStorage) XXX_Marshal 

func (m *TieredStorage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TieredStorage) XXX_Merge 

func (m *TieredStorage) XXX_Merge(src proto.Message)

func (*TieredStorage) XXX_Size 

func (m *TieredStorage) XXX_Size() int

func (*TieredStorage) XXX_Unmarshal 

func (m *TieredStorage) XXX_Unmarshal(b []byte) error

type UnitPrices 

type UnitPrices struct {
	Prices               map[string]float64 `` /* 200-byte string literal not displayed */
	Unit                 string             `protobuf:"bytes,2,opt,name=unit,proto3" json:"unit,omitempty" db:"unit,omitempty" url:"unit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*UnitPrices) Descriptor 

func (*UnitPrices) Descriptor() ([]byte, []int)

func (*UnitPrices) GetPrices 

func (m *UnitPrices) GetPrices() map[string]float64

func (*UnitPrices) GetUnit 

func (m *UnitPrices) GetUnit() string

func (*UnitPrices) Marshal 

func (m *UnitPrices) Marshal() (dAtA []byte, err error)

func (*UnitPrices) MarshalTo 

func (m *UnitPrices) MarshalTo(dAtA []byte) (int, error)

func (*UnitPrices) ProtoMessage 

func (*UnitPrices) ProtoMessage()

func (*UnitPrices) Reset 

func (m *UnitPrices) Reset()

func (*UnitPrices) Size 

func (m *UnitPrices) Size() (n int)

func (*UnitPrices) String 

func (m *UnitPrices) String() string

func (*UnitPrices) Unmarshal 

func (m *UnitPrices) Unmarshal(dAtA []byte) error

func (*UnitPrices) XXX_DiscardUnknown 

func (m *UnitPrices) XXX_DiscardUnknown()

func (*UnitPrices) XXX_Marshal 

func (m *UnitPrices) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnitPrices) XXX_Merge 

func (m *UnitPrices) XXX_Merge(src proto.Message)

func (*UnitPrices) XXX_Size 

func (m *UnitPrices) XXX_Size() int

func (*UnitPrices) XXX_Unmarshal 

func (m *UnitPrices) XXX_Unmarshal(b []byte) error

type UnknownAPIKeyError 

type UnknownAPIKeyError struct {
	APIKey string
}

func (*UnknownAPIKeyError) Error 

func (e *UnknownAPIKeyError) Error() string

type UnknownConnectorIdError 

type UnknownConnectorIdError struct {
	ConnectorId string
	Found       string
}

func (*UnknownConnectorIdError) Error 

func (e *UnknownConnectorIdError) Error() string

type UnknownLoginError 

type UnknownLoginError struct{}

func (*UnknownLoginError) Error 

func (e *UnknownLoginError) Error() string

type UpdatePaymentInfoReply 

type UpdatePaymentInfoReply struct {
	Card                 *Card         `protobuf:"bytes,1,opt,name=card,proto3" json:"card,omitempty" db:"card,omitempty" url:"card,omitempty"`
	Organization         *Organization `` /* 134-byte string literal not displayed */
	Error                *Error        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UpdatePaymentInfoReply) Descriptor 

func (*UpdatePaymentInfoReply) Descriptor() ([]byte, []int)

func (*UpdatePaymentInfoReply) GetCard 

func (m *UpdatePaymentInfoReply) GetCard() *Card

func (*UpdatePaymentInfoReply) GetError 

func (m *UpdatePaymentInfoReply) GetError() *Error

func (*UpdatePaymentInfoReply) GetOrganization 

func (m *UpdatePaymentInfoReply) GetOrganization() *Organization

func (*UpdatePaymentInfoReply) Marshal 

func (m *UpdatePaymentInfoReply) Marshal() (dAtA []byte, err error)

func (*UpdatePaymentInfoReply) MarshalTo 

func (m *UpdatePaymentInfoReply) MarshalTo(dAtA []byte) (int, error)

func (*UpdatePaymentInfoReply) ProtoMessage 

func (*UpdatePaymentInfoReply) ProtoMessage()

func (*UpdatePaymentInfoReply) Reset 

func (m *UpdatePaymentInfoReply) Reset()

func (*UpdatePaymentInfoReply) Size 

func (m *UpdatePaymentInfoReply) Size() (n int)

func (*UpdatePaymentInfoReply) String 

func (m *UpdatePaymentInfoReply) String() string

func (*UpdatePaymentInfoReply) Unmarshal 

func (m *UpdatePaymentInfoReply) Unmarshal(dAtA []byte) error

func (*UpdatePaymentInfoReply) XXX_DiscardUnknown 

func (m *UpdatePaymentInfoReply) XXX_DiscardUnknown()

func (*UpdatePaymentInfoReply) XXX_Marshal 

func (m *UpdatePaymentInfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePaymentInfoReply) XXX_Merge 

func (m *UpdatePaymentInfoReply) XXX_Merge(src proto.Message)

func (*UpdatePaymentInfoReply) XXX_Size 

func (m *UpdatePaymentInfoReply) XXX_Size() int

func (*UpdatePaymentInfoReply) XXX_Unmarshal 

func (m *UpdatePaymentInfoReply) XXX_Unmarshal(b []byte) error

type UpdatePaymentInfoRequest 

type UpdatePaymentInfoRequest struct {
	StripeToken          string            `` /* 162-byte string literal not displayed */
	Organization         *Organization     `` /* 134-byte string literal not displayed */
	RequestCarrier       map[string]string `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdatePaymentInfoRequest) Descriptor 

func (*UpdatePaymentInfoRequest) Descriptor() ([]byte, []int)

func (*UpdatePaymentInfoRequest) GetOrganization 

func (m *UpdatePaymentInfoRequest) GetOrganization() *Organization

func (*UpdatePaymentInfoRequest) GetRequestCarrier 

func (m *UpdatePaymentInfoRequest) GetRequestCarrier() map[string]string

func (*UpdatePaymentInfoRequest) GetStripeToken 

func (m *UpdatePaymentInfoRequest) GetStripeToken() string

func (*UpdatePaymentInfoRequest) Marshal 

func (m *UpdatePaymentInfoRequest) Marshal() (dAtA []byte, err error)

func (*UpdatePaymentInfoRequest) MarshalTo 

func (m *UpdatePaymentInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdatePaymentInfoRequest) ProtoMessage 

func (*UpdatePaymentInfoRequest) ProtoMessage()

func (*UpdatePaymentInfoRequest) Reset 

func (m *UpdatePaymentInfoRequest) Reset()

func (*UpdatePaymentInfoRequest) SetRequestCarrier 

func (t *UpdatePaymentInfoRequest) SetRequestCarrier(request_carrier map[string]string)

func (*UpdatePaymentInfoRequest) Size 

func (m *UpdatePaymentInfoRequest) Size() (n int)

func (*UpdatePaymentInfoRequest) String 

func (m *UpdatePaymentInfoRequest) String() string

func (*UpdatePaymentInfoRequest) Unmarshal 

func (m *UpdatePaymentInfoRequest) Unmarshal(dAtA []byte) error

func (*UpdatePaymentInfoRequest) XXX_DiscardUnknown 

func (m *UpdatePaymentInfoRequest) XXX_DiscardUnknown()

func (*UpdatePaymentInfoRequest) XXX_Marshal 

func (m *UpdatePaymentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePaymentInfoRequest) XXX_Merge 

func (m *UpdatePaymentInfoRequest) XXX_Merge(src proto.Message)

func (*UpdatePaymentInfoRequest) XXX_Size 

func (m *UpdatePaymentInfoRequest) XXX_Size() int

func (*UpdatePaymentInfoRequest) XXX_Unmarshal 

func (m *UpdatePaymentInfoRequest) XXX_Unmarshal(b []byte) error

type UpdateSchemaRegistryClusterReply 

type UpdateSchemaRegistryClusterReply struct {
	Error                *Error                 `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty" db:"error,omitempty" url:"error,omitempty"`
	ValidationErrors     map[string]string      `` /* 264-byte string literal not displayed */
	Cluster              *SchemaRegistryCluster `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdateSchemaRegistryClusterReply) Descriptor 

func (*UpdateSchemaRegistryClusterReply) Descriptor() ([]byte, []int)

func (*UpdateSchemaRegistryClusterReply) GetCluster 

func (m *UpdateSchemaRegistryClusterReply) GetCluster() *SchemaRegistryCluster

func (*UpdateSchemaRegistryClusterReply) GetError 

func (m *UpdateSchemaRegistryClusterReply) GetError() *Error

func (*UpdateSchemaRegistryClusterReply) GetValidationErrors 

func (m *UpdateSchemaRegistryClusterReply) GetValidationErrors() map[string]string

func (*UpdateSchemaRegistryClusterReply) Marshal 

func (m *UpdateSchemaRegistryClusterReply) Marshal() (dAtA []byte, err error)

func (*UpdateSchemaRegistryClusterReply) MarshalTo 

func (m *UpdateSchemaRegistryClusterReply) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSchemaRegistryClusterReply) ProtoMessage 

func (*UpdateSchemaRegistryClusterReply) ProtoMessage()

func (*UpdateSchemaRegistryClusterReply) Reset 

func (m *UpdateSchemaRegistryClusterReply) Reset()

func (*UpdateSchemaRegistryClusterReply) Size 

func (m *UpdateSchemaRegistryClusterReply) Size() (n int)

func (*UpdateSchemaRegistryClusterReply) String 

func (m *UpdateSchemaRegistryClusterReply) String() string

func (*UpdateSchemaRegistryClusterReply) Unmarshal 

func (m *UpdateSchemaRegistryClusterReply) Unmarshal(dAtA []byte) error

func (*UpdateSchemaRegistryClusterReply) XXX_DiscardUnknown 

func (m *UpdateSchemaRegistryClusterReply) XXX_DiscardUnknown()

func (*UpdateSchemaRegistryClusterReply) XXX_Marshal 

func (m *UpdateSchemaRegistryClusterReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSchemaRegistryClusterReply) XXX_Merge 

func (m *UpdateSchemaRegistryClusterReply) XXX_Merge(src proto.Message)

func (*UpdateSchemaRegistryClusterReply) XXX_Size 

func (m *UpdateSchemaRegistryClusterReply) XXX_Size() int

func (*UpdateSchemaRegistryClusterReply) XXX_Unmarshal 

func (m *UpdateSchemaRegistryClusterReply) XXX_Unmarshal(b []byte) error

type UpdateSchemaRegistryClusterRequest 

type UpdateSchemaRegistryClusterRequest struct {
	Cluster              *SchemaRegistryCluster `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty" db:"cluster,omitempty" url:"cluster,omitempty"`
	RequestCarrier       map[string]string      `` /* 265-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*UpdateSchemaRegistryClusterRequest) Descriptor 

func (*UpdateSchemaRegistryClusterRequest) Descriptor() ([]byte, []int)

func (*UpdateSchemaRegistryClusterRequest) GetCluster 

func (m *UpdateSchemaRegistryClusterRequest) GetCluster() *SchemaRegistryCluster

func (*UpdateSchemaRegistryClusterRequest) GetRequestCarrier 

func (m *UpdateSchemaRegistryClusterRequest) GetRequestCarrier() map[string]string

func (*UpdateSchemaRegistryClusterRequest) Marshal 

func (m *UpdateSchemaRegistryClusterRequest) Marshal() (dAtA []byte, err error)

func (*UpdateSchemaRegistryClusterRequest) MarshalTo 

func (m *UpdateSchemaRegistryClusterRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSchemaRegistryClusterRequest) ProtoMessage 

func (*UpdateSchemaRegistryClusterRequest) ProtoMessage()

func (*UpdateSchemaRegistryClusterRequest) Reset 

func (m *UpdateSchemaRegistryClusterRequest) Reset()

func (*UpdateSchemaRegistryClusterRequest) SetRequestCarrier 

func (t *UpdateSchemaRegistryClusterRequest) SetRequestCarrier(request_carrier map[string]string)

func (*UpdateSchemaRegistryClusterRequest) Size 

func (m *UpdateSchemaRegistryClusterRequest) Size() (n int)

func (*UpdateSchemaRegistryClusterRequest) String 

func (m *UpdateSchemaRegistryClusterRequest) String() string

func (*UpdateSchemaRegistryClusterRequest) Unmarshal 

func (m *UpdateSchemaRegistryClusterRequest) Unmarshal(dAtA []byte) error

func (*UpdateSchemaRegistryClusterRequest) XXX_DiscardUnknown 

func (m *UpdateSchemaRegistryClusterRequest) XXX_DiscardUnknown()

func (*UpdateSchemaRegistryClusterRequest) XXX_Marshal 

func (m *UpdateSchemaRegistryClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSchemaRegistryClusterRequest) XXX_Merge 

func (m *UpdateSchemaRegistryClusterRequest) XXX_Merge(src proto.Message)

func (*UpdateSchemaRegistryClusterRequest) XXX_Size 

func (m *UpdateSchemaRegistryClusterRequest) XXX_Size() int

func (*UpdateSchemaRegistryClusterRequest) XXX_Unmarshal 

func (m *UpdateSchemaRegistryClusterRequest) XXX_Unmarshal(b []byte) error

type User 

type User struct {
	Id                   int32             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" url:"id" db:"id,omitempty"`
	Email                string            `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty" url:"email" db:"email,omitempty"`
	FirstName            string            `` /* 131-byte string literal not displayed */
	LastName             string            `` /* 126-byte string literal not displayed */
	Deactivated          bool              `` /* 131-byte string literal not displayed */
	Verified             *types.Timestamp  `protobuf:"bytes,11,opt,name=verified,proto3" json:"verified,omitempty" db:"verified,omitempty" url:"verified,omitempty"`
	Created              *types.Timestamp  `protobuf:"bytes,8,opt,name=created,proto3" json:"created,omitempty" db:"created,omitempty" url:"created,omitempty"`
	Modified             *types.Timestamp  `protobuf:"bytes,9,opt,name=modified,proto3" json:"modified,omitempty" db:"modified,omitempty" url:"modified,omitempty"`
	ServiceName          string            `` /* 152-byte string literal not displayed */
	ServiceDescription   string            `` /* 187-byte string literal not displayed */
	ServiceAccount       bool              `` /* 168-byte string literal not displayed */
	Preferences          map[string]string `` /* 219-byte string literal not displayed */
	Internal             bool              `protobuf:"varint,17,opt,name=internal,proto3" json:"internal,omitempty" db:"internal,omitempty" url:"internal,omitempty"`
	ResourceId           string            `` /* 147-byte string literal not displayed */
	DeactivatedAt        *types.Timestamp  `` /* 162-byte string literal not displayed */
	SocialConnection     string            `` /* 177-byte string literal not displayed */
	AuthType             AuthType          `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*User) Descriptor 

func (*User) Descriptor() ([]byte, []int)

func (*User) GetAuthType 

func (m *User) GetAuthType() AuthType

func (*User) GetCreated 

func (m *User) GetCreated() *types.Timestamp

func (*User) GetDeactivated 

func (m *User) GetDeactivated() bool

func (*User) GetDeactivatedAt 

func (m *User) GetDeactivatedAt() *types.Timestamp

func (*User) GetEmail 

func (m *User) GetEmail() string

func (*User) GetFirstName 

func (m *User) GetFirstName() string

func (*User) GetId 

func (m *User) GetId() int32

func (*User) GetInternal 

func (m *User) GetInternal() bool

func (*User) GetLastName 

func (m *User) GetLastName() string

func (*User) GetModified 

func (m *User) GetModified() *types.Timestamp

func (*User) GetPreferences 

func (m *User) GetPreferences() map[string]string

func (*User) GetResourceId 

func (m *User) GetResourceId() string

func (*User) GetServiceAccount 

func (m *User) GetServiceAccount() bool

func (*User) GetServiceDescription 

func (m *User) GetServiceDescription() string

func (*User) GetServiceName 

func (m *User) GetServiceName() string

func (*User) GetSocialConnection 

func (m *User) GetSocialConnection() string

func (*User) GetVerified 

func (m *User) GetVerified() *types.Timestamp

func (*User) Marshal 

func (m *User) Marshal() (dAtA []byte, err error)

func (*User) MarshalTo 

func (m *User) MarshalTo(dAtA []byte) (int, error)

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) Size 

func (m *User) Size() (n int)

func (*User) String 

func (m *User) String() string

func (*User) Unmarshal 

func (m *User) Unmarshal(dAtA []byte) error

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge 

func (m *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

func (m *User) XXX_Unmarshal(b []byte) error

type UserInterface 

type UserInterface interface {
	List() ([]*User, error)
	GetServiceAccounts() ([]*User, error)
	GetServiceAccount(int32) (*User, error)
	LoginRealm(*GetLoginRealmRequest) (*GetLoginRealmReply, error)
}

User service allows managing users in Confluent Cloud

type UserService 

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

UserService provides methods for managing users on Confluent Control Plane.

func NewUserService 

func NewUserService(client *Client) *UserService

NewUserService returns a new UserService.

func (*UserService) GetServiceAccount 

func (s *UserService) GetServiceAccount(id int32) (*User, error)

GetServiceAccount returns a service account user.

func (*UserService) GetServiceAccounts 

func (s *UserService) GetServiceAccounts() ([]*User, error)

GetServiceAccounts returns a collection of service account users.

func (*UserService) List 

func (s *UserService) List() ([]*User, error)

List returns the users in the authenticated user's organization.

func (*UserService) LoginRealm 

func (s *UserService) LoginRealm(req *GetLoginRealmRequest) (*GetLoginRealmReply, error)

LoginRealm gets a user's login realm information. can be used to determine if the user is an SSO user

type Utm 

type Utm struct {
	Source               string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty" db:"source,omitempty" url:"source,omitempty"`
	Campaign             string   `protobuf:"bytes,2,opt,name=campaign,proto3" json:"campaign,omitempty" db:"campaign,omitempty" url:"campaign,omitempty"`
	Medium               string   `protobuf:"bytes,3,opt,name=medium,proto3" json:"medium,omitempty" db:"medium,omitempty" url:"medium,omitempty"`
	Partner              string   `protobuf:"bytes,4,opt,name=partner,proto3" json:"partner,omitempty" db:"partner,omitempty" url:"partner,omitempty"`
	Term                 string   `protobuf:"bytes,5,opt,name=term,proto3" json:"term,omitempty" db:"term,omitempty" url:"term,omitempty"`
	Content              string   `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty" db:"content,omitempty" url:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Utm) Descriptor 

func (*Utm) Descriptor() ([]byte, []int)

func (*Utm) GetCampaign 

func (m *Utm) GetCampaign() string

func (*Utm) GetContent 

func (m *Utm) GetContent() string

func (*Utm) GetMedium 

func (m *Utm) GetMedium() string

func (*Utm) GetPartner 

func (m *Utm) GetPartner() string

func (*Utm) GetSource 

func (m *Utm) GetSource() string

func (*Utm) GetTerm 

func (m *Utm) GetTerm() string

func (*Utm) Marshal 

func (m *Utm) Marshal() (dAtA []byte, err error)

func (*Utm) MarshalTo 

func (m *Utm) MarshalTo(dAtA []byte) (int, error)

func (*Utm) ProtoMessage 

func (*Utm) ProtoMessage()

func (*Utm) Reset 

func (m *Utm) Reset()

func (*Utm) Size 

func (m *Utm) Size() (n int)

func (*Utm) String 

func (m *Utm) String() string

func (*Utm) Unmarshal 

func (m *Utm) Unmarshal(dAtA []byte) error

func (*Utm) XXX_DiscardUnknown 

func (m *Utm) XXX_DiscardUnknown()

func (*Utm) XXX_Marshal 

func (m *Utm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Utm) XXX_Merge 

func (m *Utm) XXX_Merge(src proto.Message)

func (*Utm) XXX_Size 

func (m *Utm) XXX_Size() int

func (*Utm) XXX_Unmarshal 

func (m *Utm) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.