Documentation
¶
Index ¶
- Variables
- type AvroSettings
- func (*AvroSettings) Descriptor() ([]byte, []int)
- func (m *AvroSettings) GetAvroSchemaFile() string
- func (m *AvroSettings) GetSchema() []byte
- func (*AvroSettings) ProtoMessage()
- func (m *AvroSettings) Reset()
- func (m *AvroSettings) String() string
- func (m *AvroSettings) XXX_DiscardUnknown()
- func (m *AvroSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AvroSettings) XXX_Merge(src proto.Message)
- func (m *AvroSettings) XXX_Size() int
- func (m *AvroSettings) XXX_Unmarshal(b []byte) error
- type DecodeOptions
- func (*DecodeOptions) Descriptor() ([]byte, []int)
- func (m *DecodeOptions) GetAvroSettings() *AvroSettings
- func (m *DecodeOptions) GetDecodeType() DecodeType
- func (m *DecodeOptions) GetProtobufSettings() *ProtobufSettings
- func (m *DecodeOptions) GetSchemaId() string
- func (*DecodeOptions) ProtoMessage()
- func (m *DecodeOptions) Reset()
- func (m *DecodeOptions) String() string
- func (m *DecodeOptions) XXX_DiscardUnknown()
- func (m *DecodeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DecodeOptions) XXX_Merge(src proto.Message)
- func (m *DecodeOptions) XXX_Size() int
- func (m *DecodeOptions) XXX_Unmarshal(b []byte) error
- type DecodeType
- type EncodeOptions
- func (*EncodeOptions) Descriptor() ([]byte, []int)
- func (m *EncodeOptions) GetAvroSettings() *AvroSettings
- func (m *EncodeOptions) GetEncodeType() EncodeType
- func (m *EncodeOptions) GetProtobufSettings() *ProtobufSettings
- func (m *EncodeOptions) GetSchemaId() string
- func (*EncodeOptions) ProtoMessage()
- func (m *EncodeOptions) Reset()
- func (m *EncodeOptions) String() string
- func (m *EncodeOptions) XXX_DiscardUnknown()
- func (m *EncodeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EncodeOptions) XXX_Merge(src proto.Message)
- func (m *EncodeOptions) XXX_Size() int
- func (m *EncodeOptions) XXX_Unmarshal(b []byte) error
- type EncodeType
- type EnvelopeType
- type JSONSchemaSettings
- func (*JSONSchemaSettings) Descriptor() ([]byte, []int)
- func (m *JSONSchemaSettings) GetSchema() []byte
- func (*JSONSchemaSettings) ProtoMessage()
- func (m *JSONSchemaSettings) Reset()
- func (m *JSONSchemaSettings) String() string
- func (m *JSONSchemaSettings) XXX_DiscardUnknown()
- func (m *JSONSchemaSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *JSONSchemaSettings) XXX_Merge(src proto.Message)
- func (m *JSONSchemaSettings) XXX_Size() int
- func (m *JSONSchemaSettings) XXX_Unmarshal(b []byte) error
- type ProtobufSettings
- func (*ProtobufSettings) Descriptor() ([]byte, []int)
- func (m *ProtobufSettings) GetArchive() []byte
- func (m *ProtobufSettings) GetProtobufDirs() []string
- func (m *ProtobufSettings) GetProtobufEnvelopeType() EnvelopeType
- func (m *ProtobufSettings) GetProtobufRootMessage() string
- func (m *ProtobufSettings) GetShallowEnvelopeFieldNumber() int32
- func (m *ProtobufSettings) GetShallowEnvelopeMessage() string
- func (m *ProtobufSettings) GetXMessageDescriptor() []byte
- func (m *ProtobufSettings) GetXProtobufRootDir() string
- func (m *ProtobufSettings) GetXShallowEnvelopeMessageDescriptor() []byte
- func (*ProtobufSettings) ProtoMessage()
- func (m *ProtobufSettings) Reset()
- func (m *ProtobufSettings) String() string
- func (m *ProtobufSettings) XXX_DiscardUnknown()
- func (m *ProtobufSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProtobufSettings) XXX_Merge(src proto.Message)
- func (m *ProtobufSettings) XXX_Size() int
- func (m *ProtobufSettings) XXX_Unmarshal(b []byte) error
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 */
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) 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
Click to show internal directories.
Click to hide internal directories.