prototransform

package module

Go to main page

Versions in this module

v0

v0.4.0

Oct 4, 2023

Changes in this version

type SchemaWatcher

+ func (s *SchemaWatcher) ResolvedSchema() *descriptorpb.FileDescriptorSet

v0.3.0

Jul 24, 2023

v0.2.0

Jun 27, 2023

Changes in this version

+ var ErrLeaseStateNotYetKnown = errors.New("haven't completed initial lease check yet")

+ type Lease interface

+ Cancel func()

+ IsHeld func() (bool, error)

+ SetCallbacks func(onAcquire, onRelease func())

+ type Leaser interface

+ NewLease func(ctx context.Context, leaseName string, leaseHolder []byte) Lease

type SchemaWatcherConfig

+ CurrentProcess []byte

+ Leaser Leaser

v0.1.0

May 18, 2023

Changes in this version

+ var ErrSchemaNotModified = errors.New("no response because schema not modified")

+ var ErrSchemaWatcherNotReady = errors.New("SchemaWatcher not ready")

+ var ErrSchemaWatcherStopped = errors.New("SchemaWatcher was stopped")

+ func BufTokenFromEnvironment(moduleRef string) (string, error)

+ func HasDebugRedactOption(fd protoreflect.FieldDescriptor) bool

+ func NewAuthInterceptor(token string) connect.Interceptor

+ func NewDefaultFileDescriptorSetServiceClient(token string) reflectv1beta1connect.FileDescriptorSetServiceClient

+ type Cache interface

+ Load func(ctx context.Context, key string) ([]byte, error)

+ Save func(ctx context.Context, key string, data []byte) error

+ type Converter struct

+ Filters Filters

+ InputFormat InputFormat

+ OutputFormat OutputFormat

+ Resolver Resolver

+ func (c *Converter) ConvertMessage(messageName string, inputData []byte) ([]byte, error)

+ type Filter func(protoreflect.Message) protoreflect.Message

+ func Redact(predicate func(protoreflect.FieldDescriptor) bool) Filter

+ type Filters []Filter

+ type InputFormat interface

+ WithResolver func(Resolver) Unmarshaler

+ func BinaryInputFormat(in proto.UnmarshalOptions) InputFormat

+ func InputFormatWithoutResolver(in Unmarshaler) InputFormat

+ func JSONInputFormat(in protojson.UnmarshalOptions) InputFormat

+ func TextInputFormat(in prototext.UnmarshalOptions) InputFormat

+ type Marshaler interface

+ Marshal func(proto.Message) ([]byte, error)

+ type OutputFormat interface

+ WithResolver func(Resolver) Marshaler

+ func BinaryOutputFormat(in proto.MarshalOptions) OutputFormat

+ func JSONOutputFormat(in protojson.MarshalOptions) OutputFormat

+ func OutputFormatWithoutResolver(in Marshaler) OutputFormat

+ func TextOutputFormat(in prototext.MarshalOptions) OutputFormat

+ type Resolver interface

+ FindEnumByName func(enum protoreflect.FullName) (protoreflect.EnumType, error)

+ type SchemaPoller interface

+ GetSchema func(ctx context.Context, symbols []string, currentVersion string) (descriptors *descriptorpb.FileDescriptorSet, version string, err error)

+ GetSchemaID func() string

+ func NewSchemaPoller(client reflectv1beta1connect.FileDescriptorSetServiceClient, module string, ...) SchemaPoller

+ type SchemaWatcher struct

+ func NewSchemaWatcher(ctx context.Context, config *SchemaWatcherConfig) (*SchemaWatcher, error)

+ func (s *SchemaWatcher) AwaitReady(ctx context.Context) error

+ func (s *SchemaWatcher) FindDescriptorByName(name protoreflect.FullName) (protoreflect.Descriptor, error)

+ func (s *SchemaWatcher) FindEnumByName(enum protoreflect.FullName) (protoreflect.EnumType, error)

+ func (s *SchemaWatcher) FindExtensionByName(field protoreflect.FullName) (protoreflect.ExtensionType, error)

+ func (s *SchemaWatcher) FindExtensionByNumber(message protoreflect.FullName, field protoreflect.FieldNumber) (protoreflect.ExtensionType, error)

+ func (s *SchemaWatcher) FindFileByPath(path string) (protoreflect.FileDescriptor, error)

+ func (s *SchemaWatcher) FindMessageByName(message protoreflect.FullName) (protoreflect.MessageType, error)

+ func (s *SchemaWatcher) FindMessageByURL(url string) (protoreflect.MessageType, error)

+ func (s *SchemaWatcher) IsStopped() bool

+ func (s *SchemaWatcher) LastResolved() (bool, time.Time)

+ func (s *SchemaWatcher) RangeFiles(f func(protoreflect.FileDescriptor) bool)

+ func (s *SchemaWatcher) RangeFilesByPackage(name protoreflect.FullName, f func(protoreflect.FileDescriptor) bool)

+ func (s *SchemaWatcher) ResolveNow()

+ func (s *SchemaWatcher) Stop()

+ type SchemaWatcherConfig struct

+ Cache Cache

+ IncludeSymbols []string

+ Jitter float64

+ OnError func(error)

+ OnUpdate func()

+ PollingPeriod time.Duration

+ SchemaPoller SchemaPoller

+ type Unmarshaler interface

+ Unmarshal func([]byte, proto.Message) error

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