encoding

package
v0.0.166 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 15, 2022 License: Apache-2.0 Imports: 3 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DecodeType_name = map[int32]string{
	0: "DECODE_TYPE_UNSET",
	1: "DECODE_TYPE_PROTOBUF",
	2: "DECODE_TYPE_AVRO",
	3: "DECODE_TYPE_THRIFT",
	4: "DECODE_TYPE_FLATBUFFER",
}
View Source 
var DecodeType_value = map[string]int32{
	"DECODE_TYPE_UNSET":      0,
	"DECODE_TYPE_PROTOBUF":   1,
	"DECODE_TYPE_AVRO":       2,
	"DECODE_TYPE_THRIFT":     3,
	"DECODE_TYPE_FLATBUFFER": 4,
}
View Source 
var EncodeType_name = map[int32]string{
	0: "ENCODE_TYPE_UNSET",
	1: "ENCODE_TYPE_JSONPB",
	2: "ENCODE_TYPE_AVRO",
}
View Source 
var EncodeType_value = map[string]int32{
	"ENCODE_TYPE_UNSET":  0,
	"ENCODE_TYPE_JSONPB": 1,
	"ENCODE_TYPE_AVRO":   2,
}
View Source 
var EnvelopeType_name = map[int32]string{
	0: "ENVELOPE_TYPE_UNSET",
	1: "ENVELOPE_TYPE_DEEP",
	2: "ENVELOPE_TYPE_SHALLOW",
}
View Source 
var EnvelopeType_value = map[string]int32{
	"ENVELOPE_TYPE_UNSET":   0,
	"ENVELOPE_TYPE_DEEP":    1,
	"ENVELOPE_TYPE_SHALLOW": 2,
}

Functions

This section is empty.

Types

type AvroSettings added in v0.0.54 

type AvroSettings struct {
	// Used by CLI; desktop should not set/use this.
	// @gotags: kong:"help='If encode-type is set to avro, must specify avro schema file',existingfile"
	AvroSchemaFile string `` /* 193-byte string literal not displayed */
	// Used by desktop; CLI should not set/use this.
	// @gotags: kong:"-"
	Schema               []byte   `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty" kong:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AvroSettings) Descriptor added in v0.0.54 

func (*AvroSettings) Descriptor() ([]byte, []int)

func (*AvroSettings) GetAvroSchemaFile added in v0.0.54 

func (m *AvroSettings) GetAvroSchemaFile() string

func (*AvroSettings) GetSchema added in v0.0.54 

func (m *AvroSettings) GetSchema() []byte

func (*AvroSettings) ProtoMessage added in v0.0.54 

func (*AvroSettings) ProtoMessage()

func (*AvroSettings) Reset added in v0.0.54 

func (m *AvroSettings) Reset()

func (*AvroSettings) String added in v0.0.54 

func (m *AvroSettings) String() string

func (*AvroSettings) XXX_DiscardUnknown added in v0.0.54 

func (m *AvroSettings) XXX_DiscardUnknown()

func (*AvroSettings) XXX_Marshal added in v0.0.54 

func (m *AvroSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvroSettings) XXX_Merge added in v0.0.54 

func (m *AvroSettings) XXX_Merge(src proto.Message)

func (*AvroSettings) XXX_Size added in v0.0.54 

func (m *AvroSettings) XXX_Size() int

func (*AvroSettings) XXX_Unmarshal added in v0.0.54 

func (m *AvroSettings) XXX_Unmarshal(b []byte) error

type DecodeOptions added in v0.0.42 

type DecodeOptions struct {
	// Use an existing schema for decoding (and ignore all other decode settings)
	// @gotags: kong:"-"
	SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty" kong:"-"`
	// @gotags: kong:"help='Decode type (options: unset, protobuf, avro, thrift, flatbuffer)',type=pbenum,pbenum_strip_prefix=DECODE_TYPE_,pbenum_lowercase,default=unset"
	DecodeType DecodeType `` /* 279-byte string literal not displayed */
	// @gotags: kong:"embed,group=protobuf"
	ProtobufSettings *ProtobufSettings `` /* 137-byte string literal not displayed */
	// @gotags: kong:"embed,group=avro"
	AvroSettings         *AvroSettings `protobuf:"bytes,4,opt,name=avro_settings,json=avroSettings,proto3" json:"avro_settings,omitempty" kong:"embed,group=avro"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DecodeOptions) Descriptor added in v0.0.42 

func (*DecodeOptions) Descriptor() ([]byte, []int)

func (*DecodeOptions) GetAvroSettings added in v0.0.54 

func (m *DecodeOptions) GetAvroSettings() *AvroSettings

func (*DecodeOptions) GetDecodeType added in v0.0.49 

func (m *DecodeOptions) GetDecodeType() DecodeType

func (*DecodeOptions) GetProtobufSettings added in v0.0.49 

func (m *DecodeOptions) GetProtobufSettings() *ProtobufSettings

func (*DecodeOptions) GetSchemaId added in v0.0.42 

func (m *DecodeOptions) GetSchemaId() string

func (*DecodeOptions) ProtoMessage added in v0.0.42 

func (*DecodeOptions) ProtoMessage()

func (*DecodeOptions) Reset added in v0.0.42 

func (m *DecodeOptions) Reset()

func (*DecodeOptions) String added in v0.0.42 

func (m *DecodeOptions) String() string

func (*DecodeOptions) XXX_DiscardUnknown added in v0.0.42 

func (m *DecodeOptions) XXX_DiscardUnknown()

func (*DecodeOptions) XXX_Marshal added in v0.0.42 

func (m *DecodeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DecodeOptions) XXX_Merge added in v0.0.42 

func (m *DecodeOptions) XXX_Merge(src proto.Message)

func (*DecodeOptions) XXX_Size added in v0.0.42 

func (m *DecodeOptions) XXX_Size() int

func (*DecodeOptions) XXX_Unmarshal added in v0.0.42 

func (m *DecodeOptions) XXX_Unmarshal(b []byte) error

type DecodeType added in v0.0.49 

type DecodeType int32
const (
	DecodeType_DECODE_TYPE_UNSET      DecodeType = 0
	DecodeType_DECODE_TYPE_PROTOBUF   DecodeType = 1
	DecodeType_DECODE_TYPE_AVRO       DecodeType = 2
	DecodeType_DECODE_TYPE_THRIFT     DecodeType = 3
	DecodeType_DECODE_TYPE_FLATBUFFER DecodeType = 4
)

func (DecodeType) EnumDescriptor added in v0.0.49 

func (DecodeType) EnumDescriptor() ([]byte, []int)

func (DecodeType) String added in v0.0.49 

func (x DecodeType) String() string

type EncodeOptions added in v0.0.42 

type EncodeOptions struct {
	// Use an existing schema for encoding (and ignore all other encode settings)
	// @gotags: kong:"-"
	SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty" kong:"-"`
	// @gotags: kong:"help='Encode type (options: unset, jsonpb, avro)',default=unset,type=pbenum,pbenum_strip_prefix=ENCODE_TYPE_,pbenum_lowercase"
	EncodeType EncodeType `` /* 257-byte string literal not displayed */
	// @gotags: kong:"embed,group=protobuf"
	ProtobufSettings *ProtobufSettings `` /* 137-byte string literal not displayed */
	// @gotags: kong:"embed,group=avro"
	AvroSettings         *AvroSettings `protobuf:"bytes,4,opt,name=avro_settings,json=avroSettings,proto3" json:"avro_settings,omitempty" kong:"embed,group=avro"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*EncodeOptions) Descriptor added in v0.0.42 

func (*EncodeOptions) Descriptor() ([]byte, []int)

func (*EncodeOptions) GetAvroSettings added in v0.0.54 

func (m *EncodeOptions) GetAvroSettings() *AvroSettings

func (*EncodeOptions) GetEncodeType added in v0.0.49 

func (m *EncodeOptions) GetEncodeType() EncodeType

func (*EncodeOptions) GetProtobufSettings added in v0.0.49 

func (m *EncodeOptions) GetProtobufSettings() *ProtobufSettings

func (*EncodeOptions) GetSchemaId added in v0.0.42 

func (m *EncodeOptions) GetSchemaId() string

func (*EncodeOptions) ProtoMessage added in v0.0.42 

func (*EncodeOptions) ProtoMessage()

func (*EncodeOptions) Reset added in v0.0.42 

func (m *EncodeOptions) Reset()

func (*EncodeOptions) String added in v0.0.42 

func (m *EncodeOptions) String() string

func (*EncodeOptions) XXX_DiscardUnknown added in v0.0.42 

func (m *EncodeOptions) XXX_DiscardUnknown()

func (*EncodeOptions) XXX_Marshal added in v0.0.42 

func (m *EncodeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EncodeOptions) XXX_Merge added in v0.0.42 

func (m *EncodeOptions) XXX_Merge(src proto.Message)

func (*EncodeOptions) XXX_Size added in v0.0.42 

func (m *EncodeOptions) XXX_Size() int

func (*EncodeOptions) XXX_Unmarshal added in v0.0.42 

func (m *EncodeOptions) XXX_Unmarshal(b []byte) error

type EncodeType added in v0.0.49 

type EncodeType int32
const (
	EncodeType_ENCODE_TYPE_UNSET  EncodeType = 0
	EncodeType_ENCODE_TYPE_JSONPB EncodeType = 1
	EncodeType_ENCODE_TYPE_AVRO   EncodeType = 2
)

func (EncodeType) EnumDescriptor added in v0.0.49 

func (EncodeType) EnumDescriptor() ([]byte, []int)

func (EncodeType) String added in v0.0.49 

func (x EncodeType) String() string

type EnvelopeType added in v0.0.120 

type EnvelopeType int32
const (
	EnvelopeType_ENVELOPE_TYPE_UNSET   EnvelopeType = 0
	EnvelopeType_ENVELOPE_TYPE_DEEP    EnvelopeType = 1
	EnvelopeType_ENVELOPE_TYPE_SHALLOW EnvelopeType = 2
)

func (EnvelopeType) EnumDescriptor added in v0.0.120 

func (EnvelopeType) EnumDescriptor() ([]byte, []int)

func (EnvelopeType) String added in v0.0.120 

func (x EnvelopeType) String() string

type JSONSchemaSettings added in v0.0.79 

type JSONSchemaSettings struct {
	// Used by desktop; CLI should not set/use this.
	// @gotags: kong:"-"
	Schema               []byte   `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty" kong:"-"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JSONSchemaSettings) Descriptor added in v0.0.79 

func (*JSONSchemaSettings) Descriptor() ([]byte, []int)

func (*JSONSchemaSettings) GetSchema added in v0.0.79 

func (m *JSONSchemaSettings) GetSchema() []byte

func (*JSONSchemaSettings) ProtoMessage added in v0.0.79 

func (*JSONSchemaSettings) ProtoMessage()

func (*JSONSchemaSettings) Reset added in v0.0.79 

func (m *JSONSchemaSettings) Reset()

func (*JSONSchemaSettings) String added in v0.0.79 

func (m *JSONSchemaSettings) String() string

func (*JSONSchemaSettings) XXX_DiscardUnknown added in v0.0.79 

func (m *JSONSchemaSettings) XXX_DiscardUnknown()

func (*JSONSchemaSettings) XXX_Marshal added in v0.0.79 

func (m *JSONSchemaSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JSONSchemaSettings) XXX_Merge added in v0.0.79 

func (m *JSONSchemaSettings) XXX_Merge(src proto.Message)

func (*JSONSchemaSettings) XXX_Size added in v0.0.79 

func (m *JSONSchemaSettings) XXX_Size() int

func (*JSONSchemaSettings) XXX_Unmarshal added in v0.0.79 

func (m *JSONSchemaSettings) XXX_Unmarshal(b []byte) error

type ProtobufSettings added in v0.0.49 

type ProtobufSettings struct {
	// @gotags: kong:"help='Input message(s) should be encoded with this message envelope'"
	ProtobufRootMessage string `` /* 196-byte string literal not displayed */
	// Desktop/server should not use this.
	// @gotags: kong:"help='One or more directories which contains protobuf schemas',existingdir"
	ProtobufDirs []string `` /* 179-byte string literal not displayed */
	// Directory where protos are stored (used for github import)
	// @gotags: kong:"-"
	XProtobufRootDir string `protobuf:"bytes,3,opt,name=_protobuf_root_dir,json=ProtobufRootDir,proto3" json:"_protobuf_root_dir,omitempty" kong:"-"`
	// Used by server/desktop when creating a read without an existing schema
	// @gotags: kong:"-"
	Archive []byte `protobuf:"bytes,4,opt,name=archive,proto3" json:"archive,omitempty" kong:"-"`
	// Used internally by the server
	// @gotags: kong:"-"
	XMessageDescriptor []byte `protobuf:"bytes,5,opt,name=_message_descriptor,json=MessageDescriptor,proto3" json:"_message_descriptor,omitempty" kong:"-"`
	// @gotags: kong:"help='Envelope type (options: deep, shallow)',type=pbenum,pbenum_strip_prefix=ENVELOPE_TYPE_,pbenum_lowercase,default=deep"
	ProtobufEnvelopeType EnvelopeType `` /* 288-byte string literal not displayed */
	// @gotags: kong:"help='For shallow envelope messages, the payload field should be encoded with this message name'"
	ShallowEnvelopeMessage string `` /* 233-byte string literal not displayed */
	// @gotags: kong:"help='For shallow envelope messages, the field number of the root message that contains the shallow envelope payload'"
	ShallowEnvelopeFieldNumber int32 `` /* 269-byte string literal not displayed */
	// Used internally by the server
	// @gotags: kong:"-"
	XShallowEnvelopeMessageDescriptor []byte `` /* 172-byte string literal not displayed */
	// @gotags: kong:"help='Protobuf descriptor set(.protoset or .fds file)'"
	ProtobufDescriptorSet string   `` /* 189-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*ProtobufSettings) Descriptor added in v0.0.49 

func (*ProtobufSettings) Descriptor() ([]byte, []int)

func (*ProtobufSettings) GetArchive added in v0.0.54 

func (m *ProtobufSettings) GetArchive() []byte

func (*ProtobufSettings) GetProtobufDescriptorSet added in v0.0.160 

func (m *ProtobufSettings) GetProtobufDescriptorSet() string

func (*ProtobufSettings) GetProtobufDirs added in v0.0.49 

func (m *ProtobufSettings) GetProtobufDirs() []string

func (*ProtobufSettings) GetProtobufEnvelopeType added in v0.0.120 

func (m *ProtobufSettings) GetProtobufEnvelopeType() EnvelopeType

func (*ProtobufSettings) GetProtobufRootMessage added in v0.0.49 

func (m *ProtobufSettings) GetProtobufRootMessage() string

func (*ProtobufSettings) GetShallowEnvelopeFieldNumber added in v0.0.120 

func (m *ProtobufSettings) GetShallowEnvelopeFieldNumber() int32

func (*ProtobufSettings) GetShallowEnvelopeMessage added in v0.0.120 

func (m *ProtobufSettings) GetShallowEnvelopeMessage() string

func (*ProtobufSettings) GetXMessageDescriptor added in v0.0.56 

func (m *ProtobufSettings) GetXMessageDescriptor() []byte

func (*ProtobufSettings) GetXProtobufRootDir added in v0.0.56 

func (m *ProtobufSettings) GetXProtobufRootDir() string

func (*ProtobufSettings) GetXShallowEnvelopeMessageDescriptor added in v0.0.120 

func (m *ProtobufSettings) GetXShallowEnvelopeMessageDescriptor() []byte

func (*ProtobufSettings) ProtoMessage added in v0.0.49 

func (*ProtobufSettings) ProtoMessage()

func (*ProtobufSettings) Reset added in v0.0.49 

func (m *ProtobufSettings) Reset()

func (*ProtobufSettings) String added in v0.0.49 

func (m *ProtobufSettings) String() string

func (*ProtobufSettings) XXX_DiscardUnknown added in v0.0.49 

func (m *ProtobufSettings) XXX_DiscardUnknown()

func (*ProtobufSettings) XXX_Marshal added in v0.0.49 

func (m *ProtobufSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProtobufSettings) XXX_Merge added in v0.0.49 

func (m *ProtobufSettings) XXX_Merge(src proto.Message)

func (*ProtobufSettings) XXX_Size added in v0.0.49 

func (m *ProtobufSettings) XXX_Size() int

func (*ProtobufSettings) XXX_Unmarshal added in v0.0.49 

func (m *ProtobufSettings) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.