cmd

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	APIKeysFileName = "apikeys.yaml"
	HistoryFile     = "cli.hist"
)
View Source 
const (
	ClusterFLag          = "cluster"
	DescriptionFlag      = "description"
	WorkspaceFlag        = "workspace"
	WorkspaceShortFlag   = "W"
	RetentionFlag        = "retention"
	CompressionFlag      = "compression"
	IntegrationFlag      = "integration"
	RegionFlag           = "region"
	BucketFlag           = "bucket"
	PatternFlag          = "pattern"
	RoleARNFlag          = "role-arn"
	DatasetFlag          = "dataset"
	WaitFlag             = "wait"
	ValidateFlag         = "validate"
	FileFlag             = "file"
	ContextFLag          = "context"
	DebugFlag            = "debug"
	SizeFlag             = "size"
	IngestTransformation = "ingest-transformation"

	FormatFlag = "format"
	WideFlag   = "wide"
	HeaderFlag = "header"
	ForceFlag  = "force"
)
View Source 
const (
	DefaultFormat    = "table"
	DefaultWorkspace = "commons"
	AllWorkspaces    = "all"
)
View Source 
const VersionURL = "http://rockset.sh/install/version.json"

Variables

View Source 
var (
	R       = color.CyanString("[") + color.MagentaString("R") + color.CyanString("]")
	Rockset = color.CyanString("[") + color.MagentaString("Rockset") + color.CyanString("]")
	Version = "development"
)
View Source 
var APIKeysFile string
View Source 
var VINotFoundErr = errors.New("virtual instance not found")

Functions

func FormatFromCommand 

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

func NewRootCmd 

func NewRootCmd(version string) *cobra.Command

func VersionCheck added in v0.0.2 

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

Types

type APIKey added in v0.0.7 

type APIKey struct {
	Key    string `yaml:"apikey"`
	Server string `yaml:"apiserver"`
}

type APIKeys added in v0.0.7 

type APIKeys struct {
	Current string            `yaml:"current"`
	Keys    map[string]APIKey `yaml:"configs"`
}

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 added in v0.0.2 

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

Source Files

View all Source files

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.