provider

Documentation

Index

• Constants
• func ParseIPWhitelist(ips string) ([]string, error)
• type AivenProvider
  • func New(configJSON []byte) (*AivenProvider, error)
  • func (ap *AivenProvider) Bind(ctx context.Context, bindData BindData) (binding brokerapi.Binding, err error)
  • func (ap *AivenProvider) Deprovision(ctx context.Context, deprovisionData DeprovisionData) (operationData string, err error)
  • func (ap *AivenProvider) LastOperation(ctx context.Context, lastOperationData LastOperationData) (state brokerapi.LastOperationState, description string, err error)
  • func (ap *AivenProvider) Provision(ctx context.Context, provisionData ProvisionData) (dashboardURL, operationData string, err error)
  • func (ap *AivenProvider) Unbind(ctx context.Context, unbindData UnbindData) (err error)
  • func (ap *AivenProvider) Update(ctx context.Context, updateData UpdateData) (operationData string, err error)
• type AivenServiceCommonConfig
• type AivenServiceElasticsearchConfig
• type AivenServiceInfluxDBConfig
• type BindData
• type Catalog
• type CommonCredentials
• type Config
  • func DecodeConfig(b []byte) (*Config, error)
  • func (c *Config) FindPlan(serviceId, planId string) (*Plan, error)
• type Credentials
  • func BuildCredentials(serviceType string, username string, password string, hostname string, ...) (Credentials, error)
• type DeprovisionData
• type InfluxDBCredentials
• type InfluxDBPrometheusBasicAuthCredentials
• type InfluxDBPrometheusCredentials
• type InfluxDBPrometheusRemoteCredentials
• type LastOperationData
• type Plan
• type PlanSpecificConfig
• type ProvisionData
• type Service
• type ServiceProvider
• type UnbindData
• type UpdateData

Constants

const AIVEN_BASE_URL string = "https://api.aiven.io"

Functions

func ParseIPWhitelist

func ParseIPWhitelist(ips string) ([]string, error)

Types

type AivenProvider

type AivenProvider struct {
	Client aiven.Client
	Config *Config
}

func New

func New(configJSON []byte) (*AivenProvider, error)

func (*AivenProvider) Bind

func (ap *AivenProvider) Bind(ctx context.Context, bindData BindData) (binding brokerapi.Binding, err error)

func (*AivenProvider) Deprovision

func (ap *AivenProvider) Deprovision(ctx context.Context, deprovisionData DeprovisionData) (operationData string, err error)

func (*AivenProvider) LastOperation

func (ap *AivenProvider) LastOperation(
	ctx context.Context,
	lastOperationData LastOperationData,
) (state brokerapi.LastOperationState, description string, err error)

func (*AivenProvider) Provision

func (ap *AivenProvider) Provision(ctx context.Context, provisionData ProvisionData) (dashboardURL, operationData string, err error)

func (*AivenProvider) Unbind

func (ap *AivenProvider) Unbind(ctx context.Context, unbindData UnbindData) (err error)

func (*AivenProvider) Update

func (ap *AivenProvider) Update(ctx context.Context, updateData UpdateData) (operationData string, err error)

type AivenServiceCommonConfig

type AivenServiceCommonConfig struct{}

type AivenServiceElasticsearchConfig

type AivenServiceElasticsearchConfig struct {
	ElasticsearchVersion string `json:"elasticsearch_version"`
}

type AivenServiceInfluxDBConfig

type AivenServiceInfluxDBConfig struct{}

type BindData

type BindData struct {
	InstanceID string
	BindingID  string
	Details    brokerapi.BindDetails
}

type Catalog

type Catalog struct {
	Services []Service `json:"services"`
}

type CommonCredentials

type CommonCredentials struct {
	URI      string `json:"uri"`
	Hostname string `json:"hostname"`
	Port     string `json:"port"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type Config

type Config struct {
	Cloud             string `json:"cloud"`
	ServiceNamePrefix string
	APIToken          string
	Project           string
	Catalog           Catalog `json:"catalog"`
}

func DecodeConfig

func DecodeConfig(b []byte) (*Config, error)

func (*Config) FindPlan

func (c *Config) FindPlan(serviceId, planId string) (*Plan, error)

type Credentials

type Credentials struct {
	CommonCredentials

	InfluxDBCredentials
}

func BuildCredentials

func BuildCredentials(
	serviceType string,
	username string,
	password string,
	hostname string,
	port string,
) (Credentials, error)

type DeprovisionData

type DeprovisionData struct {
	InstanceID string
	Details    brokerapi.DeprovisionDetails
	Service    brokerapi.Service
	Plan       brokerapi.ServicePlan
}

type InfluxDBCredentials

type InfluxDBCredentials struct {
	InfluxDBPrometheus *InfluxDBPrometheusCredentials `json:"prometheus,omitempty"`
}

type InfluxDBPrometheusBasicAuthCredentials

type InfluxDBPrometheusBasicAuthCredentials struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type InfluxDBPrometheusCredentials

type InfluxDBPrometheusCredentials struct {
	RemoteRead  []InfluxDBPrometheusRemoteCredentials `json:"remote_read"`
	RemoteWrite []InfluxDBPrometheusRemoteCredentials `json:"remote_write"`
}

type InfluxDBPrometheusRemoteCredentials

type InfluxDBPrometheusRemoteCredentials struct {
	URL                  string                                 `json:"url"`
	BasicAuthCredentials InfluxDBPrometheusBasicAuthCredentials `json:"basic_auth"`
}

type LastOperationData

type LastOperationData struct {
	InstanceID    string
	OperationData string
}

type Plan

type Plan struct {
	brokerapi.ServicePlan
	PlanSpecificConfig
}

type PlanSpecificConfig

type PlanSpecificConfig struct {
	AivenPlan string `json:"aiven_plan"`

	AivenServiceCommonConfig
	AivenServiceElasticsearchConfig
	AivenServiceInfluxDBConfig
}

type ProvisionData

type ProvisionData struct {
	InstanceID string
	Details    brokerapi.ProvisionDetails
	Service    brokerapi.Service
	Plan       brokerapi.ServicePlan
}

type Service

type Service struct {
	brokerapi.Service
	Plans []Plan `json:"plans"`
}

type ServiceProvider

type ServiceProvider interface {
	Provision(context.Context, ProvisionData) (dashboardURL, operationData string, err error)
	Deprovision(context.Context, DeprovisionData) (operationData string, err error)
	Bind(context.Context, BindData) (binding brokerapi.Binding, err error)
	Unbind(context.Context, UnbindData) (err error)
	Update(context.Context, UpdateData) (operationData string, err error)
	LastOperation(context.Context, LastOperationData) (state brokerapi.LastOperationState, description string, err error)
}

type UnbindData

type UnbindData struct {
	InstanceID string
	BindingID  string
	Details    brokerapi.UnbindDetails
}

type UpdateData

type UpdateData struct {
	InstanceID string
	Details    brokerapi.UpdateDetails
	Service    brokerapi.Service
	Plan       brokerapi.ServicePlan
}