Versions in this module Expand all Collapse all v0 v0.0.2 Apr 15, 2024 Changes in this version + var AllFormatsString = stringutil.SliceToString(allFormatsNotDeprecated) + var MessageFormatsString = stringutil.SliceToString(messageFormatsNotDeprecated) + var ModuleFormatsString = stringutil.SliceToString(moduleFormatsNotDeprecated) + var SourceDirFormatsString = stringutil.SliceToString(sourceDirFormatsNotDeprecated) + var SourceFormatsString = stringutil.SliceToString(sourceFormatsNotDeprecated) + var SourceOrModuleFormatsString = stringutil.SliceToString(sourceOrModuleFormatsNotDeprecated) + type GetSourceBucketOption func(*getSourceBucketOptions) + func GetSourceBucketWithWorkspacesDisabled() GetSourceBucketOption + type MessageEncoding int + const MessageEncodingBinpb + const MessageEncodingJSON + const MessageEncodingTxtpb + const MessageEncodingYAML + type MessageReader interface + GetMessageFile func(ctx context.Context, container app.EnvStdinContainer, messageRef MessageRef) (io.ReadCloser, error) + func NewMessageReader(logger *zap.Logger, storageosProvider storageos.Provider, ...) MessageReader + type MessageRef interface + IsNull func() bool + MessageEncoding func() MessageEncoding + Path func() string + UseEnumNumbers func() bool + UseProtoNames func() bool + type MessageRefParser interface + GetMessageRef func(ctx context.Context, value string) (MessageRef, error) + func NewMessageRefParser(logger *zap.Logger, options ...MessageRefParserOption) MessageRefParser + type MessageRefParserOption func(*messageRefParserOptions) + func MessageRefParserWithDefaultMessageEncoding(defaultMessageEncoding MessageEncoding) MessageRefParserOption + type ModuleFetcher interface + GetModule func(ctx context.Context, container app.EnvStdinContainer, moduleRef ModuleRef) (bufmodule.Module, error) + func NewModuleFetcher(logger *zap.Logger, storageosProvider storageos.Provider, ...) ModuleFetcher + type ModuleRef interface + type ModuleRefParser interface + GetModuleRef func(ctx context.Context, value string) (ModuleRef, error) + func NewModuleRefParser(logger *zap.Logger) ModuleRefParser + type PathResolver interface + PathForExternalPath func(externalPath string) (string, error) + type ProtoFileRef interface + IncludePackageFiles func() bool + type ReadBucketCloser internal.ReadBucketCloser + type ReadBucketCloserWithTerminateFileProvider internal.ReadBucketCloserWithTerminateFileProvider + type ReadWriteBucketCloser internal.ReadWriteBucketCloser + type Reader interface + func NewReader(logger *zap.Logger, storageosProvider storageos.Provider, ...) Reader + type Ref interface + type RefParser interface + GetRef func(ctx context.Context, value string) (Ref, error) + func NewRefParser(logger *zap.Logger) RefParser + type SourceOrModuleRef interface + type SourceOrModuleRefParser interface + GetSourceOrModuleRef func(ctx context.Context, value string) (SourceOrModuleRef, error) + func NewSourceOrModuleRefParser(logger *zap.Logger) SourceOrModuleRefParser + type SourceReader interface + GetSourceBucket func(ctx context.Context, container app.EnvStdinContainer, sourceRef SourceRef, ...) (ReadBucketCloserWithTerminateFileProvider, error) + func NewSourceReader(logger *zap.Logger, storageosProvider storageos.Provider, ...) SourceReader + type SourceRef interface + type SourceRefParser interface + GetSourceRef func(ctx context.Context, value string) (SourceRef, error) + func NewSourceRefParser(logger *zap.Logger) SourceRefParser + type Writer interface + PutMessageFile func(ctx context.Context, container app.EnvStdoutContainer, messageRef MessageRef) (io.WriteCloser, error) + func NewWriter(logger *zap.Logger) Writer