snowflake

Documentation

Index

• Variables
• type Client
• type ClientInfo
  • func GetClientInfo(ctx context.Context, c client.Client, mg resource.Managed) (*ClientInfo, error)
  • func UseProviderConfig(ctx context.Context, c client.Client, mg resource.Managed) (*ClientInfo, error)
  • func (c ClientInfo) CreateDatabase(ctx context.Context, db *v1alpha1.DatabaseParameters) (string, error)
  • func (c ClientInfo) DeleteDatabase(ctx context.Context, dbName string) error
  • func (c ClientInfo) FetchDatabase(ctx context.Context, dbinfo DbInfo)
  • func (c ClientInfo) ListDatabase(ctx context.Context, dbinfo DbInfo)
  • func (c *ClientInfo) MakeRequest(method string, api_path string, payload map[string]interface{})
  • func (c ClientInfo) UpdateDatabase(ctx context.Context, dbinfo DbInfo)
• type DatabaseClient
• type DbInfo

Variables

var ErrNotFound = errors.New("Not found")

Types

type Client

type Client interface {
	// TableClient
	DatabaseClient
}

type ClientInfo

type ClientInfo struct {
	SnowflakeAccount string
	JwtToken         string
	// contains filtered or unexported fields
}

func GetClientInfo

func GetClientInfo(ctx context.Context, c client.Client, mg resource.Managed) (*ClientInfo, error)

all helper method

func UseProviderConfig

func UseProviderConfig(ctx context.Context, c client.Client, mg resource.Managed) (*ClientInfo, error)

func (ClientInfo) CreateDatabase

func (c ClientInfo) CreateDatabase(ctx context.Context, db *v1alpha1.DatabaseParameters) (string, error)

create database

func (ClientInfo) DeleteDatabase

func (c ClientInfo) DeleteDatabase(ctx context.Context, dbName string) error

func (ClientInfo) FetchDatabase

func (c ClientInfo) FetchDatabase(ctx context.Context, dbinfo DbInfo)

func (ClientInfo) ListDatabase

func (c ClientInfo) ListDatabase(ctx context.Context, dbinfo DbInfo)

func (*ClientInfo) MakeRequest

func (c *ClientInfo) MakeRequest(method string, api_path string, payload map[string]interface{})

func (ClientInfo) UpdateDatabase

func (c ClientInfo) UpdateDatabase(ctx context.Context, dbinfo DbInfo)

type DatabaseClient

type DatabaseClient interface {
	ListDatabase(ctx context.Context, dbinfo DbInfo)
	FetchDatabase(ctx context.Context, dbinfo DbInfo)
	CreateDatabase(ctx context.Context, db *dbv1alpha1.DatabaseParameters) (string, error)
	DeleteDatabase(ctx context.Context, db *dbv1alpha1.DatabaseParameters) error
	UpdateDatabase(ctx context.Context, dbinfo DbInfo)
}

type DbInfo

type DbInfo struct {
	DbName string
	Kind   string
}