cmd

Documentation

Index

• Constants
• Variables
• func FormatFromCommand(cmd *cobra.Command) format.Format
• func Map[IN, OUT any](array []IN, fn func(IN) OUT) []OUT
• func NewCreateAliasCmd() *cobra.Command
• func NewDeleteAliasCmd() *cobra.Command
• func NewExecuteQueryLambdaCmd() *cobra.Command
• func NewGetAliasCmd() *cobra.Command
• func NewGetWorkspaceCmd() *cobra.Command
• func NewListAliasesCmd() *cobra.Command
• func NewRootCmd(version string) *cobra.Command
• func NewUpdateAliasCmd() *cobra.Command
• func VersionCheck(ctx context.Context, ch chan string)
• type DocumentAdder
• type StreamConfig
• type Streamer
  • func NewStreamer(s DocumentAdder, cfg StreamConfig) Streamer
  • func (s *Streamer) Stream(ctx context.Context, in io.Reader) (uint64, error)
• type Versions

Constants

const (
	DefaultAuthProvider = "auth0"
	DefaultAuthServer   = "auth.rockset.com"
	DefaultClientID     = "0dJNiGWClbLjg7AdtXtAyPCeE0jKOFet"
)

const (
	ClusterFLag  = "cluster"
	ContextFLag  = "context"
	DebugFlag    = "debug"
	FormatFlag   = "format"
	HeaderFlag   = "header"
	SelectorFlag = "selector"
	WideFlag     = "wide"
)

global flags

const (
	BucketFlag           = "bucket"
	CompressionFlag      = "compression"
	CollectionFlag       = "collection"
	DatasetFlag          = "dataset"
	DescriptionFlag      = "description"
	FileFlag             = "file"
	ForceFlag            = "force"
	IngestTransformation = "ingest-transformation"
	IntegrationFlag      = "integration"
	PatternFlag          = "pattern"
	RegionFlag           = "region"
	RetentionFlag        = "retention"
	RoleARNFlag          = "role-arn"
	SizeFlag             = "size"
	SQLFlag              = "sql"
	TagFlag              = "tag"
	TagsFlag             = "tags"
	ValidateFlag         = "validate"
	VersionFlag          = "version"
	VersionsFlag         = "versions"
	WaitFlag             = "wait"
	WorkspaceFlag        = "workspace"
	WorkspaceShortFlag   = "W"
)

command specific flags

const (
	AllWorkspaces    = "all"
	DefaultFormat    = "table"
	DefaultWorkspace = "commons"
)

const VersionURL = "http://rockset.sh/install/version.json"

Variables

var VINotFoundErr = errors.New("virtual instance not found")

var (
	Version = "development"
)

Functions

func FormatFromCommand

func FormatFromCommand(cmd *cobra.Command) format.Format

func Map

func Map[IN, OUT any](array []IN, fn func(IN) OUT) []OUT

func NewCreateAliasCmd

func NewCreateAliasCmd() *cobra.Command

func NewDeleteAliasCmd

func NewDeleteAliasCmd() *cobra.Command

func NewExecuteQueryLambdaCmd

func NewExecuteQueryLambdaCmd() *cobra.Command

func NewGetAliasCmd

func NewGetAliasCmd() *cobra.Command

func NewGetWorkspaceCmd

func NewGetWorkspaceCmd() *cobra.Command

func NewListAliasesCmd

func NewListAliasesCmd() *cobra.Command

func NewRootCmd

func NewRootCmd(version string) *cobra.Command

func NewUpdateAliasCmd

func NewUpdateAliasCmd() *cobra.Command

func VersionCheck

func VersionCheck(ctx context.Context, ch chan string)

Types

type DocumentAdder

type DocumentAdder interface {
	AddDocuments(ctx context.Context, workspace, collection string,
		docs []interface{}) ([]openapi.DocumentStatus, error)
}

type StreamConfig

type StreamConfig struct {
	Workspace  string
	Collection string
	BatchSize  uint64
}

type Streamer

type Streamer struct {
	StreamConfig
	// contains filtered or unexported fields
}

func NewStreamer

func NewStreamer(s DocumentAdder, cfg StreamConfig) Streamer

func (*Streamer) Stream

func (s *Streamer) Stream(ctx context.Context, in io.Reader) (uint64, error)

type Versions

type Versions struct {
	Stable string `json:"stable"`
	Beta   string `json:"beta"`
}