Documentation ¶
Index ¶
- Variables
- type DecodeOptions
- func (*DecodeOptions) Descriptor() ([]byte, []int)
- func (m *DecodeOptions) GetInput() map[string]string
- func (m *DecodeOptions) GetMetadata() map[string]string
- func (m *DecodeOptions) GetSchemaId() string
- func (m *DecodeOptions) GetType() Type
- 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 EncodeOptions
- func (*EncodeOptions) Descriptor() ([]byte, []int)
- func (m *EncodeOptions) GetInput() map[string]string
- func (m *EncodeOptions) GetMetadata() map[string]string
- func (m *EncodeOptions) GetSchemaId() string
- func (m *EncodeOptions) GetType() Type
- 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 Type
Constants ¶
This section is empty.
Variables ¶
View Source
var Type_name = map[int32]string{
0: "TYPE_UNSET",
1: "TYPE_PLAIN",
2: "TYPE_PROTOBUF",
3: "TYPE_AVRO",
4: "TYPE_THRIFT",
5: "TYPE_FLATBUFFER",
}
View Source
var Type_value = map[string]int32{
"TYPE_UNSET": 0,
"TYPE_PLAIN": 1,
"TYPE_PROTOBUF": 2,
"TYPE_AVRO": 3,
"TYPE_THRIFT": 4,
"TYPE_FLATBUFFER": 5,
}
Functions ¶
This section is empty.
Types ¶
type DecodeOptions ¶ added in v0.0.42
type DecodeOptions struct { // The type of decoder selected determines which Encoding should be used (if any) // NOTE: This type will also determine which metadata k:v's need to be set. // @gotags: kong:"name=decoder,help='How to decode output (valid TYPEs: 1: Plain, 2 = Protobuf, 3 = Avro, 4 = Thrift, 5 = FlatBuffer)',default=1" // TODO: ^ This sucks and needs to be improved. Not sure how yet. Type Type `` /* 222-byte string literal not displayed */ // Specify an existing stored schema to use instead of specifying a Encoding payload // @gotags: kong:"-" SchemaId string `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty" kong:"-"` // Valid input keys: dir, file, string, github, zip // TODO: Help needs to outline all of the available options here // TODO: This needs to improve as well. Probably new 'map_keys' tag? // @gotags: kong:"name='decoder-input',required" Input map[string]string `` /* 188-byte string literal not displayed */ // Valid input keys: // TODO: Help needs to outline all of the available options here // TODO: Same, needs to be improved? Not sure how. // @gotags: name:"decoder-metadata" Metadata map[string]string `` /* 181-byte string literal not displayed */ 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) GetInput ¶ added in v0.0.42
func (m *DecodeOptions) GetInput() map[string]string
func (*DecodeOptions) GetMetadata ¶ added in v0.0.42
func (m *DecodeOptions) GetMetadata() map[string]string
func (*DecodeOptions) GetSchemaId ¶ added in v0.0.42
func (m *DecodeOptions) GetSchemaId() string
func (*DecodeOptions) GetType ¶ added in v0.0.42
func (m *DecodeOptions) GetType() Type
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 EncodeOptions ¶ added in v0.0.42
type EncodeOptions struct { // The type of decoder selected determines which Encoding should be used (if any). // NOTE: This type will also determine which metadata k:v's need to be set. // @gotags: kong:"name=encoder,help='How to encode input. NOTE: The type of encoder selected determines which Encoding should be used (if any). Valid TYPEs 1: PLAIN, 2: Protobuf, 3: Avro, 4: Thrift, 5: Flatbuffer',default=1" Type Type `` /* 301-byte string literal not displayed */ // Specify an existing stored schema to use instead of specifying a Encoding payload // @gotags: kong:"-" SchemaId string `protobuf:"bytes,2,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty" kong:"-"` // Valid input keys: dir, file, string, github, zip // TODO: Help needs to outline all of the available options here // @gotags: name:"encoder-input" Input map[string]string `` /* 172-byte string literal not displayed */ // Valid input keys: // TODO: Help needs to outline all of the available options here // @gotags: name:"encoder-metadata" Metadata map[string]string `` /* 181-byte string literal not displayed */ 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) GetInput ¶ added in v0.0.42
func (m *EncodeOptions) GetInput() map[string]string
func (*EncodeOptions) GetMetadata ¶ added in v0.0.42
func (m *EncodeOptions) GetMetadata() map[string]string
func (*EncodeOptions) GetSchemaId ¶ added in v0.0.42
func (m *EncodeOptions) GetSchemaId() string
func (*EncodeOptions) GetType ¶ added in v0.0.42
func (m *EncodeOptions) GetType() Type
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
Click to show internal directories.
Click to hide internal directories.