protos

Documentation

Index

• Constants
• func AllocateDynamicMessage(ctx context.Context, pctx ParseContext, ...) (protoreflect.ProtoMessage, error)
• func AllocateFrom(ctx context.Context, pctx ParseContext, value map[string]any) (proto.Message, error)
• func AllocateWellKnownMessage(ctx context.Context, pctx ParseContext, ...) (protoreflect.ProtoMessage, error)
• func CheckConsolidate[V proto.Message](check V, out *V) bool
• func Clone[V proto.Message](msg V) V
• func NewFromType[V proto.Message]() V
• func TypeUrl[V proto.Message]() string
• func TypeUrlForInstance(m proto.Message) string
• func WrapAnyOrDie(src protoreflect.ProtoMessage) *anypb.Any
• func WrapAnysOrDie(srcs ...protoreflect.ProtoMessage) []*anypb.Any
• func WriteFile(path string, msg proto.Message) error
• type ParseContext
• type SerializeOpts
  • func (opts SerializeOpts) Serialize(msgs ...proto.Message) ([]TextAndBinary, error)
  • func (opts SerializeOpts) SerializeToFS(ctx context.Context, target fnfs.WriteFS, m map[string]proto.Message) error
• type TextAndBinary
  • func SerializeMultiple(msgs ...proto.Message) ([]TextAndBinary, error)

Constants

const TypeUrlPrefix = "type.googleapis.com/"

Functions

func AllocateDynamicMessage

func AllocateDynamicMessage(ctx context.Context, pctx ParseContext, messageType protoreflect.MessageDescriptor, value any) (protoreflect.ProtoMessage, error)

func AllocateFrom

func AllocateFrom(ctx context.Context, pctx ParseContext, value map[string]any) (proto.Message, error)

func AllocateWellKnownMessage

func AllocateWellKnownMessage(ctx context.Context, pctx ParseContext, messageType protoreflect.MessageDescriptor, value any) (protoreflect.ProtoMessage, error)

func CheckConsolidate

func CheckConsolidate[V proto.Message](check V, out *V) bool

func Clone

func Clone[V proto.Message](msg V) V

func NewFromType

func NewFromType[V proto.Message]() V

func TypeUrl

func TypeUrl[V proto.Message]() string

func TypeUrlForInstance

func TypeUrlForInstance(m proto.Message) string

func WrapAnyOrDie

func WrapAnyOrDie(src protoreflect.ProtoMessage) *anypb.Any

func WrapAnysOrDie

func WrapAnysOrDie(srcs ...protoreflect.ProtoMessage) []*anypb.Any

func WriteFile

func WriteFile(path string, msg proto.Message) error

Types

type ParseContext

type ParseContext struct {
	SupportWellKnownMessages bool
	FS                       fs.FS
	PackageName              schema.PackageName
	EnsurePackage            func(schema.PackageName) error
}

type SerializeOpts

type SerializeOpts struct {
	TextProto bool
	JSON      bool
	Resolver  interface {
		protoregistry.ExtensionTypeResolver
		protoregistry.MessageTypeResolver
	}
}

func (SerializeOpts) Serialize

func (opts SerializeOpts) Serialize(msgs ...proto.Message) ([]TextAndBinary, error)

func (SerializeOpts) SerializeToFS

func (opts SerializeOpts) SerializeToFS(ctx context.Context, target fnfs.WriteFS, m map[string]proto.Message) error

type TextAndBinary

type TextAndBinary struct {
	Text   []byte
	JSON   []byte
	Binary []byte

	PerFormat map[string][]byte // Key, one of: binarypb, textpb, json
}

func SerializeMultiple

func SerializeMultiple(msgs ...proto.Message) ([]TextAndBinary, error)