cmd

package

v0.0.25 Latest Latest Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rockset/cli

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func GithubVersionCheck(ctx context.Context, ch chan string)
func Map[IN, OUT any](array []IN, fn func(IN) OUT) []OUT
func NewCreateAPIKeyCmd() *cobra.Command
func NewCreateAliasCmd() *cobra.Command
func NewDeleteAPIKeyCmd() *cobra.Command
func NewDeleteAliasCmd() *cobra.Command
func NewExecuteQueryLambdaCmd() *cobra.Command
func NewGetAPIKeyCmd() *cobra.Command
func NewGetAliasCmd() *cobra.Command
func NewGetMountCmd() *cobra.Command
func NewGetWorkspaceCmd() *cobra.Command
func NewListAPIKeysCmd() *cobra.Command
func NewListAliasesCmd() *cobra.Command
func NewListMountsCmd() *cobra.Command
func NewMountCollectionsCmd() *cobra.Command
func NewRootCmd(version string) *cobra.Command
func NewUnmountCollectionCmd() *cobra.Command
func NewUpdateAliasCmd() *cobra.Command
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)

Constants ¶

View Source

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

Variables ¶

View Source

var (
	Version = "development"
)

Functions ¶

func GithubVersionCheck ¶ added in v0.0.21

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

func Map ¶ added in v0.0.14

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

func NewCreateAPIKeyCmd ¶ added in v0.0.22

func NewCreateAPIKeyCmd() *cobra.Command

func NewCreateAliasCmd ¶ added in v0.0.14

func NewCreateAliasCmd() *cobra.Command

func NewDeleteAPIKeyCmd ¶ added in v0.0.22

func NewDeleteAPIKeyCmd() *cobra.Command

func NewDeleteAliasCmd ¶ added in v0.0.14

func NewDeleteAliasCmd() *cobra.Command

func NewExecuteQueryLambdaCmd ¶ added in v0.0.14

func NewExecuteQueryLambdaCmd() *cobra.Command

func NewGetAPIKeyCmd ¶ added in v0.0.22

func NewGetAPIKeyCmd() *cobra.Command

func NewGetAliasCmd ¶ added in v0.0.14

func NewGetAliasCmd() *cobra.Command

func NewGetMountCmd ¶ added in v0.0.22

func NewGetMountCmd() *cobra.Command

func NewGetWorkspaceCmd ¶ added in v0.0.14

func NewGetWorkspaceCmd() *cobra.Command

func NewListAPIKeysCmd ¶ added in v0.0.22

func NewListAPIKeysCmd() *cobra.Command

func NewListAliasesCmd ¶ added in v0.0.14

func NewListAliasesCmd() *cobra.Command

func NewListMountsCmd ¶ added in v0.0.22

func NewListMountsCmd() *cobra.Command

func NewMountCollectionsCmd ¶ added in v0.0.22

func NewMountCollectionsCmd() *cobra.Command

func NewRootCmd ¶

func NewRootCmd(version string) *cobra.Command

func NewUnmountCollectionCmd ¶ added in v0.0.22

func NewUnmountCollectionCmd() *cobra.Command

func NewUpdateAliasCmd ¶ added in v0.0.14

func NewUpdateAliasCmd() *cobra.Command

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)

Source Files ¶

View all Source files

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