cmd

package

v0.0.13 Latest Latest Go to latest Published: Oct 17, 2023 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rockset/cli

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func FormatFromCommand(cmd *cobra.Command) format.Format
func NewRootCmd(version string) *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 ¶

View Source

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

global flags

View Source

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"
	ValidateFlag         = "validate"
	WaitFlag             = "wait"
	WorkspaceFlag        = "workspace"
	WorkspaceShortFlag   = "W"
)

command specific flags

View Source

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

View Source

const Auth0ClientID = "0dJNiGWClbLjg7AdtXtAyPCeE0jKOFet"

View Source

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

Variables ¶

View Source

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

View Source

var (
	Version = "development"
)

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 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"`
}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func FormatFromCommand ¶

func NewRootCmd ¶

func VersionCheck ¶ added in v0.0.2

Types ¶

type DocumentAdder ¶

type StreamConfig ¶

type Streamer ¶

func NewStreamer ¶

func (*Streamer) Stream ¶

type Versions ¶ added in v0.0.2

Source Files ¶