Versions in this module Expand all Collapse all v1 v1.1.5 Apr 27, 2020 v1.1.3 Oct 21, 2019 Changes in this version + const ClientFormat + const DEFAULT_BACKUP_FORMAT + const DEFAULT_CREATE_FORMAT + const DEFAULT_DELETE_FORMAT + const DEFAULT_MODELTYPE_LIST_FORMAT + const DEFAULT_SERVICE_FORMAT + const DEFAULT_SYNC_FORMAT + const DEFAULT_TRANSFER_FORMAT + const DEFAULT_UPDATE_FORMAT + const DefaultFormat + const FILTER_ALL + const FILTER_DEFAULT + const FILTER_DELETED + const FILTER_DELETEDPOL + const FILTER_DIRTY + const FILTER_DIRTYPOL + const GM_QUIET + const GM_UNTIL_ENACTED + const GM_UNTIL_FOUND + const GM_UNTIL_STATUS + const INIT_DEFAULT + const INIT_NO_VERSION_CHECK + const ServerFormat + const StatusListFormat + var CharReplacer = strings.NewReplacer("\\t", "\t", "\\n", "\n") + var OutputStream io.Writer = os.Stdout + func CheckModelName(source grpcurl.DescriptorSource, name string) error + func CommaSeparatedQueryToMap(query_str string, allow_inequality bool) (map[string]string, error) + func Confirmf(format string, args ...interface{}) bool + func CreateDynamicURI() (string, string) + func CreateModel(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, modelName string, ...) error + func DecodeOperator(query string) (string, string, bool, error) + func DeleteModel(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, modelName string, ...) error + func FilterModels(ctx context.Context, conn *grpc.ClientConn, ...) ([]*dynamic.Message, error) + func FindModel(ctx context.Context, conn *grpc.ClientConn, ...) (*dynamic.Message, error) + func FindModelWithRetry(ctx context.Context, conn *grpc.ClientConn, ...) (*grpc.ClientConn, *dynamic.Message, error) + func FormatAndGenerateListOutput(options *ListOutputOptions, default_format string, quiet_format string, ...) + func FormatAndGenerateOutput(options *OutputOptions, default_format string, quiet_format string, ...) + func GenerateHeaders() []string + func GenerateOutput(result *CommandResult) + func GetEnumValue(msg *dynamic.Message, name string) string + func GetFilterKind(kindArg string) (string, error) + func GetIDList(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, modelName string, ...) ([]int32, error) + func GetModel(ctx context.Context, conn *grpc.ClientConn, ...) (*dynamic.Message, error) + func GetModelNames(source grpcurl.DescriptorSource) (map[string]bool, error) + func GetModelWithRetry(ctx context.Context, conn *grpc.ClientConn, ...) (*grpc.ClientConn, *dynamic.Message, error) + func GetReflectionMethod(conn *grpc.ClientConn, name string) (grpcurl.DescriptorSource, string, error) + func GetVersion(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource) (*dynamic.Message, error) + func GrpcTimeoutContext(ctx context.Context) (context.Context, context.CancelFunc) + func InitClient(flags uint32) (*grpc.ClientConn, grpcurl.DescriptorSource, error) + func IsEnacted(d *dynamic.Message) bool + func IsFileUri(s string) bool + func ItemsToDynamicMessageList(items interface{}) []*dynamic.Message + func ListModels(ctx context.Context, conn *grpc.ClientConn, ...) ([]*dynamic.Message, error) + func ListOrFilterModels(ctx context.Context, conn *grpc.ClientConn, ...) ([]*dynamic.Message, error) + func MessageToMap(d *dynamic.Message) map[string]interface + func NewConnection() (*grpc.ClientConn, error) + func QueryStringsToMap(query_args []string, allow_inequality bool) (map[string]string, error) + func RegisterBackupCommands(parser *flags.Parser) + func RegisterCompletionCommands(parent *flags.Parser) + func RegisterConfigCommands(parent *flags.Parser) + func RegisterModelCommands(parser *flags.Parser) + func RegisterModelTypeCommands(parser *flags.Parser) + func RegisterServiceCommands(parser *flags.Parser) + func RegisterStatusCommands(parser *flags.Parser) + func RegisterTransferCommands(parser *flags.Parser) + func RegisterVersionCommands(parent *flags.Parser) + func SetEnumValue(msg *dynamic.Message, name string, value string) + func Ternary_uint32(condition bool, value_true uint32, value_false uint32) uint32 + func TypeConvert(source grpcurl.DescriptorSource, modelName string, field_name string, v string) (interface{}, error) + func UpdateModel(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, modelName string, ...) error + func UpdateModelStatusOutput(output *ModelStatusOutput, i int, id interface{}, status string, err error, ...) + type BackupCreate struct + Args struct{ ... } + ChunkSize int + func (options *BackupCreate) Execute(args []string) error + type BackupOpts struct + Create BackupCreate + Restore BackupRestore + type BackupOutput struct + Bytes int + Checksum string + Chunks int + Status string + type BackupRestore struct + Args struct{ ... } + ChunkSize int + CreateURIFunc func() (string, string) + func (options *BackupRestore) Execute(args []string) error + type BashOptions struct + func (options *BashOptions) Execute(args []string) error + type CommandResult struct + Data interface{} + Format format.Format + OrderBy string + OutputAs OutputType + type CompletionOptions struct + type ConfigOptions struct + func (options *ConfigOptions) Execute(args []string) error + type CoreVersionDetails struct + Arch string + BuildTime string + DjangoVersion string + GitCommit string + Os string + PythonVersion string + Version string + type DescriptorNotFoundError struct + Version string + func (e *DescriptorNotFoundError) Error() string + type DownloadHandler struct + func DownloadFile(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, uri string, ...) (*DownloadHandler, error) + func (h *DownloadHandler) GetChecksum() string + func (h *DownloadHandler) OnReceiveResponse(m proto.Message) + type ListOutputOptions struct + OrderBy string + type MethodNotFoundError struct + Name string + func (e *MethodNotFoundError) Error() string + type MethodVersionNotFoundError struct + Name string + Version string + func (e *MethodVersionNotFoundError) Error() string + type ModelCreate struct + Args struct{ ... } + SetFields string + SetJSON string + Sync bool + SyncTimeout time.Duration + Unbuffered bool + func (options *ModelCreate) Execute(args []string) error + type ModelDelete struct + All bool + Args struct{ ... } + Filter string + IDArgs struct{ ... } + Unbuffered bool + func (options *ModelDelete) Execute(args []string) error + type ModelList struct + Args struct{ ... } + Filter string + ShowBookkeeping bool + ShowFeedback bool + ShowHidden bool + State string + func (options *ModelList) Execute(args []string) error + type ModelNameString string + func (modelName *ModelNameString) Complete(match string) []flags.Completion + type ModelOpts struct + Create ModelCreate + Delete ModelDelete + List ModelList + SetDirty ModelSetDirty + Sync ModelSync + Update ModelUpdate + type ModelSetDirty struct + All bool + Args struct{ ... } + Filter string + IDArgs struct{ ... } + Unbuffered bool + func (options *ModelSetDirty) Execute(args []string) error + type ModelStatusOutput struct + Rows []ModelStatusOutputRow + Unbuffered bool + func InitModelStatusOutput(unbuffered bool, count int) ModelStatusOutput + type ModelStatusOutputRow struct + Id interface{} + Message string + type ModelSync struct + All bool + Args struct{ ... } + Filter string + IDArgs struct{ ... } + SyncTimeout time.Duration + Unbuffered bool + func (options *ModelSync) Execute(args []string) error + type ModelTypeList struct + func (options *ModelTypeList) Execute(args []string) error + type ModelTypeOpts struct + List ModelTypeList + type ModelUpdate struct + Args struct{ ... } + Filter string + IDArgs struct{ ... } + SetFields string + SetJSON string + Sync bool + SyncTimeout time.Duration + Unbuffered bool + func (options *ModelUpdate) Execute(args []string) error + type OutputOptions struct + Format string + OutputAs string + Quiet bool + type OutputType uint8 + const CORE_VERSION_CONSTRAINT + const OUTPUT_JSON + const OUTPUT_TABLE + const OUTPUT_YAML + type QueryEventHandler struct + EOF bool + Elements map[string]string + Kind string + Model *desc.MessageDescriptor + func (h *QueryEventHandler) GetParams(msg proto.Message) error + type RpcEventHandler struct + Data []byte + Fields map[string]map[string]interface{} + Response proto.Message + Status *status.Status + func (h *RpcEventHandler) GetParams(msg proto.Message) error + func (h *RpcEventHandler) OnReceiveHeaders(metadata.MD) + func (h *RpcEventHandler) OnReceiveResponse(m proto.Message) + func (h *RpcEventHandler) OnReceiveTrailers(s *status.Status, m metadata.MD) + func (h *RpcEventHandler) OnResolveMethod(*desc.MethodDescriptor) + func (h *RpcEventHandler) OnSendHeaders(metadata.MD) + type ServiceList struct + func (options *ServiceList) Execute(args []string) error + type ServiceListOutput struct + Name string + State string + Version string + type ServiceOpts struct + List ServiceList + type StatusListOpts struct + Filter string + func (options *StatusListOpts) Execute(args []string) error + type StatusOpts struct + List StatusListOpts + type TransferDownload struct + Args struct{ ... } + func (options *TransferDownload) Execute(args []string) error + type TransferOpts struct + Download TransferDownload + Upload TransferUpload + type TransferOutput struct + Bytes int + Checksum string + Chunks int + Status string + type TransferUpload struct + Args struct{ ... } + ChunkSize int + func (options *TransferUpload) Execute(args []string) error + type UnableToParseDescriptorErrror struct + Version string + func (e *UnableToParseDescriptorErrror) Error() string + type UploadHandler struct + func UploadFile(conn *grpc.ClientConn, descriptor grpcurl.DescriptorSource, local_name string, ...) (*UploadHandler, *dynamic.Message, error) + func (h *UploadHandler) GetChecksum() string + func (h *UploadHandler) GetParams(msg proto.Message) error + type VersionDetails struct + Arch string + BuildTime string + GitCommit string + GitDirty string + GoVersion string + Os string + Version string + type VersionOpts struct + ClientOnly bool + OutputAs string + func (options *VersionOpts) Execute(args []string) error + type VersionOutput struct + Client VersionDetails + Server CoreVersionDetails