encoding

package
v0.0.185 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EncodeType_name = map[int32]string{
		0: "ENCODE_TYPE_UNSET",
		1: "ENCODE_TYPE_JSONPB",
		2: "ENCODE_TYPE_AVRO",
		3: "ENCODE_TYPE_CLOUDEVENT",
	}
	EncodeType_value = map[string]int32{
		"ENCODE_TYPE_UNSET":      0,
		"ENCODE_TYPE_JSONPB":     1,
		"ENCODE_TYPE_AVRO":       2,
		"ENCODE_TYPE_CLOUDEVENT": 3,
	}
)

Enum value maps for EncodeType.

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",
	}
	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,
	}
)

Enum value maps for DecodeType.

View Source 
var (
	EnvelopeType_name = map[int32]string{
		0: "ENVELOPE_TYPE_UNSET",
		1: "ENVELOPE_TYPE_DEEP",
		2: "ENVELOPE_TYPE_SHALLOW",
	}
	EnvelopeType_value = map[string]int32{
		"ENVELOPE_TYPE_UNSET":   0,
		"ENVELOPE_TYPE_DEEP":    1,
		"ENVELOPE_TYPE_SHALLOW": 2,
	}
)

Enum value maps for EnvelopeType.

View Source 
var File_ps_encoding_options_proto protoreflect.FileDescriptor

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:"-"`
	// contains filtered or unexported fields
}

func (*AvroSettings) Descriptor deprecated added in v0.0.54 

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

Deprecated: Use AvroSettings.ProtoReflect.Descriptor instead.

func (*AvroSettings) GetAvroSchemaFile added in v0.0.54 

func (x *AvroSettings) GetAvroSchemaFile() string

func (*AvroSettings) GetSchema added in v0.0.54 

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

func (*AvroSettings) ProtoMessage added in v0.0.54 

func (*AvroSettings) ProtoMessage()

func (*AvroSettings) ProtoReflect added in v0.0.181 

func (x *AvroSettings) ProtoReflect() protoreflect.Message

func (*AvroSettings) Reset added in v0.0.54 

func (x *AvroSettings) Reset()

func (*AvroSettings) String added in v0.0.54 

func (x *AvroSettings) String() string

type CloudEventSettings added in v0.0.180 

type CloudEventSettings struct {

	// @gotags: kong:"help='ID to give cloud event. If left blank, plumber will auto-generate a random UUIDv4'"
	CeId string `` /* 169-byte string literal not displayed */
	// @gotags: kong:"help='Source for cloud event',default='plumber'"
	CeSource string `` /* 140-byte string literal not displayed */
	// @gotags: kong:"help='Cloud event type'"
	CeType string `protobuf:"bytes,3,opt,name=ce_type,json=ceType,proto3" json:"ce_type,omitempty" kong:"help='Cloud event type'"`
	// @gotags: kong:"help='Cloud event subject'"
	CeSubject string `protobuf:"bytes,4,opt,name=ce_subject,json=ceSubject,proto3" json:"ce_subject,omitempty" kong:"help='Cloud event subject'"`
	// @gotags: kong:"help='Cloud event specification version, ex: 0.1, 0.2, 0.3, 1.0',default='1.0'"
	CeSpecVersion string `` /* 188-byte string literal not displayed */
	// @gotags: kong:"help='Type of encoding of the event data',default='application/json; charset=utf-8'"
	CeDataContentType string `` /* 207-byte string literal not displayed */
	// @gotags: kong:"help='Path to JSON schema file for the cloud event'"
	CeDataSchema string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CloudEventSettings) Descriptor deprecated added in v0.0.180 

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

Deprecated: Use CloudEventSettings.ProtoReflect.Descriptor instead.

func (*CloudEventSettings) GetCeDataContentType added in v0.0.180 

func (x *CloudEventSettings) GetCeDataContentType() string

func (*CloudEventSettings) GetCeDataSchema added in v0.0.180 

func (x *CloudEventSettings) GetCeDataSchema() string

func (*CloudEventSettings) GetCeId added in v0.0.180 

func (x *CloudEventSettings) GetCeId() string

func (*CloudEventSettings) GetCeSource added in v0.0.180 

func (x *CloudEventSettings) GetCeSource() string

func (*CloudEventSettings) GetCeSpecVersion added in v0.0.180 

func (x *CloudEventSettings) GetCeSpecVersion() string

func (*CloudEventSettings) GetCeSubject added in v0.0.180 

func (x *CloudEventSettings) GetCeSubject() string

func (*CloudEventSettings) GetCeType added in v0.0.180 

func (x *CloudEventSettings) GetCeType() string

func (*CloudEventSettings) ProtoMessage added in v0.0.180 

func (*CloudEventSettings) ProtoMessage()

func (*CloudEventSettings) ProtoReflect added in v0.0.181 

func (x *CloudEventSettings) ProtoReflect() protoreflect.Message

func (*CloudEventSettings) Reset added in v0.0.180 

func (x *CloudEventSettings) Reset()

func (*CloudEventSettings) String added in v0.0.180 

func (x *CloudEventSettings) String() string

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"`
	// @gotags: kong:"embed,group=thrift"
	ThriftSettings *ThriftSettings `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DecodeOptions) Descriptor deprecated added in v0.0.42 

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

Deprecated: Use DecodeOptions.ProtoReflect.Descriptor instead.

func (*DecodeOptions) GetAvroSettings added in v0.0.54 

func (x *DecodeOptions) GetAvroSettings() *AvroSettings

func (*DecodeOptions) GetDecodeType added in v0.0.49 

func (x *DecodeOptions) GetDecodeType() DecodeType

func (*DecodeOptions) GetProtobufSettings added in v0.0.49 

func (x *DecodeOptions) GetProtobufSettings() *ProtobufSettings

func (*DecodeOptions) GetSchemaId added in v0.0.42 

func (x *DecodeOptions) GetSchemaId() string

func (*DecodeOptions) GetThriftSettings added in v0.0.168 

func (x *DecodeOptions) GetThriftSettings() *ThriftSettings

func (*DecodeOptions) ProtoMessage added in v0.0.42 

func (*DecodeOptions) ProtoMessage()

func (*DecodeOptions) ProtoReflect added in v0.0.181 

func (x *DecodeOptions) ProtoReflect() protoreflect.Message

func (*DecodeOptions) Reset added in v0.0.42 

func (x *DecodeOptions) Reset()

func (*DecodeOptions) String added in v0.0.42 

func (x *DecodeOptions) String() string

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) Descriptor added in v0.0.181 

func (DecodeType) Descriptor() protoreflect.EnumDescriptor

func (DecodeType) Enum added in v0.0.181 

func (x DecodeType) Enum() *DecodeType

func (DecodeType) EnumDescriptor deprecated added in v0.0.49 

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

Deprecated: Use DecodeType.Descriptor instead.

func (DecodeType) Number added in v0.0.181 

func (x DecodeType) Number() protoreflect.EnumNumber

func (DecodeType) String added in v0.0.49 

func (x DecodeType) String() string

func (DecodeType) Type added in v0.0.181 

func (DecodeType) Type() protoreflect.EnumType

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"`
	// @gotags: kong:"embed,group=cloudevent"
	CloudeventSettings *CloudEventSettings `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EncodeOptions) Descriptor deprecated added in v0.0.42 

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

Deprecated: Use EncodeOptions.ProtoReflect.Descriptor instead.

func (*EncodeOptions) GetAvroSettings added in v0.0.54 

func (x *EncodeOptions) GetAvroSettings() *AvroSettings

func (*EncodeOptions) GetCloudeventSettings added in v0.0.180 

func (x *EncodeOptions) GetCloudeventSettings() *CloudEventSettings

func (*EncodeOptions) GetEncodeType added in v0.0.49 

func (x *EncodeOptions) GetEncodeType() EncodeType

func (*EncodeOptions) GetProtobufSettings added in v0.0.49 

func (x *EncodeOptions) GetProtobufSettings() *ProtobufSettings

func (*EncodeOptions) GetSchemaId added in v0.0.42 

func (x *EncodeOptions) GetSchemaId() string

func (*EncodeOptions) ProtoMessage added in v0.0.42 

func (*EncodeOptions) ProtoMessage()

func (*EncodeOptions) ProtoReflect added in v0.0.181 

func (x *EncodeOptions) ProtoReflect() protoreflect.Message

func (*EncodeOptions) Reset added in v0.0.42 

func (x *EncodeOptions) Reset()

func (*EncodeOptions) String added in v0.0.42 

func (x *EncodeOptions) String() string

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
	EncodeType_ENCODE_TYPE_CLOUDEVENT EncodeType = 3
)

func (EncodeType) Descriptor added in v0.0.181 

func (EncodeType) Descriptor() protoreflect.EnumDescriptor

func (EncodeType) Enum added in v0.0.181 

func (x EncodeType) Enum() *EncodeType

func (EncodeType) EnumDescriptor deprecated added in v0.0.49 

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

Deprecated: Use EncodeType.Descriptor instead.

func (EncodeType) Number added in v0.0.181 

func (x EncodeType) Number() protoreflect.EnumNumber

func (EncodeType) String added in v0.0.49 

func (x EncodeType) String() string

func (EncodeType) Type added in v0.0.181 

func (EncodeType) Type() protoreflect.EnumType

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) Descriptor added in v0.0.181 

func (EnvelopeType) Descriptor() protoreflect.EnumDescriptor

func (EnvelopeType) Enum added in v0.0.181 

func (x EnvelopeType) Enum() *EnvelopeType

func (EnvelopeType) EnumDescriptor deprecated added in v0.0.120 

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

Deprecated: Use EnvelopeType.Descriptor instead.

func (EnvelopeType) Number added in v0.0.181 

func (x EnvelopeType) Number() protoreflect.EnumNumber

func (EnvelopeType) String added in v0.0.120 

func (x EnvelopeType) String() string

func (EnvelopeType) Type added in v0.0.181 

func (EnvelopeType) Type() protoreflect.EnumType

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:"-"`
	// contains filtered or unexported fields
}

func (*JSONSchemaSettings) Descriptor deprecated added in v0.0.79 

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

Deprecated: Use JSONSchemaSettings.ProtoReflect.Descriptor instead.

func (*JSONSchemaSettings) GetSchema added in v0.0.79 

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

func (*JSONSchemaSettings) ProtoMessage added in v0.0.79 

func (*JSONSchemaSettings) ProtoMessage()

func (*JSONSchemaSettings) ProtoReflect added in v0.0.181 

func (x *JSONSchemaSettings) ProtoReflect() protoreflect.Message

func (*JSONSchemaSettings) Reset added in v0.0.79 

func (x *JSONSchemaSettings) Reset()

func (*JSONSchemaSettings) String added in v0.0.79 

func (x *JSONSchemaSettings) String() string

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 */
	// contains filtered or unexported fields
}

func (*ProtobufSettings) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use ProtobufSettings.ProtoReflect.Descriptor instead.

func (*ProtobufSettings) GetArchive added in v0.0.54 

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

func (*ProtobufSettings) GetProtobufDescriptorSet added in v0.0.160 

func (x *ProtobufSettings) GetProtobufDescriptorSet() string

func (*ProtobufSettings) GetProtobufDirs added in v0.0.49 

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

func (*ProtobufSettings) GetProtobufEnvelopeType added in v0.0.120 

func (x *ProtobufSettings) GetProtobufEnvelopeType() EnvelopeType

func (*ProtobufSettings) GetProtobufRootMessage added in v0.0.49 

func (x *ProtobufSettings) GetProtobufRootMessage() string

func (*ProtobufSettings) GetShallowEnvelopeFieldNumber added in v0.0.120 

func (x *ProtobufSettings) GetShallowEnvelopeFieldNumber() int32

func (*ProtobufSettings) GetShallowEnvelopeMessage added in v0.0.120 

func (x *ProtobufSettings) GetShallowEnvelopeMessage() string

func (*ProtobufSettings) GetXMessageDescriptor added in v0.0.56 

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

func (*ProtobufSettings) GetXProtobufRootDir added in v0.0.56 

func (x *ProtobufSettings) GetXProtobufRootDir() string

func (*ProtobufSettings) GetXShallowEnvelopeMessageDescriptor added in v0.0.120 

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

func (*ProtobufSettings) ProtoMessage added in v0.0.49 

func (*ProtobufSettings) ProtoMessage()

func (*ProtobufSettings) ProtoReflect added in v0.0.181 

func (x *ProtobufSettings) ProtoReflect() protoreflect.Message

func (*ProtobufSettings) Reset added in v0.0.49 

func (x *ProtobufSettings) Reset()

func (*ProtobufSettings) String added in v0.0.49 

func (x *ProtobufSettings) String() string

type ThriftSettings added in v0.0.168 

type ThriftSettings struct {

	// @gotags: kong:"help='One or more directories containing Thrift IDL files'"
	ThriftDirs []string `` /* 157-byte string literal not displayed */
	// @gotags: kong:"help='Namespace and struct name to decode the message with. Ex: com.mycompany.Account'"
	ThriftStruct string `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ThriftSettings) Descriptor deprecated added in v0.0.168 

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

Deprecated: Use ThriftSettings.ProtoReflect.Descriptor instead.

func (*ThriftSettings) GetThriftDirs added in v0.0.168 

func (x *ThriftSettings) GetThriftDirs() []string

func (*ThriftSettings) GetThriftStruct added in v0.0.168 

func (x *ThriftSettings) GetThriftStruct() string

func (*ThriftSettings) ProtoMessage added in v0.0.168 

func (*ThriftSettings) ProtoMessage()

func (*ThriftSettings) ProtoReflect added in v0.0.181 

func (x *ThriftSettings) ProtoReflect() protoreflect.Message

func (*ThriftSettings) Reset added in v0.0.168 

func (x *ThriftSettings) Reset()

func (*ThriftSettings) String added in v0.0.168 

func (x *ThriftSettings) String() string

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.