records

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2020 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GenericRecord 

type GenericRecord struct {
	Body                 []byte            `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	Source               string            `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Timestamp            int64             `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GenericRecord) Descriptor 

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

func (*GenericRecord) GetBody 

func (m *GenericRecord) GetBody() []byte

func (*GenericRecord) GetMetadata 

func (m *GenericRecord) GetMetadata() map[string]string

func (*GenericRecord) GetSource 

func (m *GenericRecord) GetSource() string

func (*GenericRecord) GetTimestamp 

func (m *GenericRecord) GetTimestamp() int64

func (*GenericRecord) ProtoMessage 

func (*GenericRecord) ProtoMessage()

func (*GenericRecord) Reset 

func (m *GenericRecord) Reset()

func (*GenericRecord) String 

func (m *GenericRecord) String() string

func (*GenericRecord) XXX_DiscardUnknown 

func (m *GenericRecord) XXX_DiscardUnknown()

func (*GenericRecord) XXX_Marshal 

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

func (*GenericRecord) XXX_Merge 

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

func (*GenericRecord) XXX_Size 

func (m *GenericRecord) XXX_Size() int

func (*GenericRecord) XXX_Unmarshal 

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

type HTTPRecord 

type HTTPRecord struct {
	Method               string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Headers              map[string]string `` /* 155-byte string literal not displayed */
	Path                 string            `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Source               string            `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Body                 []byte            `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	Timestamp            int64             `protobuf:"varint,6,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*HTTPRecord) Descriptor 

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

func (*HTTPRecord) GetBody 

func (m *HTTPRecord) GetBody() []byte

func (*HTTPRecord) GetHeaders 

func (m *HTTPRecord) GetHeaders() map[string]string

func (*HTTPRecord) GetMethod 

func (m *HTTPRecord) GetMethod() string

func (*HTTPRecord) GetPath 

func (m *HTTPRecord) GetPath() string

func (*HTTPRecord) GetSource 

func (m *HTTPRecord) GetSource() string

func (*HTTPRecord) GetTimestamp 

func (m *HTTPRecord) GetTimestamp() int64

func (*HTTPRecord) ProtoMessage 

func (*HTTPRecord) ProtoMessage()

func (*HTTPRecord) Reset 

func (m *HTTPRecord) Reset()

func (*HTTPRecord) String 

func (m *HTTPRecord) String() string

func (*HTTPRecord) XXX_DiscardUnknown 

func (m *HTTPRecord) XXX_DiscardUnknown()

func (*HTTPRecord) XXX_Marshal 

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

func (*HTTPRecord) XXX_Merge 

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

func (*HTTPRecord) XXX_Size 

func (m *HTTPRecord) XXX_Size() int

func (*HTTPRecord) XXX_Unmarshal 

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

type KafkaSinkRecord 

type KafkaSinkRecord struct {
	Topic                string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Key                  []byte   `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Timestamp            int64    `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Offset               int64    `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Partition            int32    `protobuf:"varint,6,opt,name=partition,proto3" json:"partition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaSinkRecord) Descriptor 

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

func (*KafkaSinkRecord) GetKey 

func (m *KafkaSinkRecord) GetKey() []byte

func (*KafkaSinkRecord) GetOffset 

func (m *KafkaSinkRecord) GetOffset() int64

func (*KafkaSinkRecord) GetPartition 

func (m *KafkaSinkRecord) GetPartition() int32

func (*KafkaSinkRecord) GetTimestamp 

func (m *KafkaSinkRecord) GetTimestamp() int64

func (*KafkaSinkRecord) GetTopic 

func (m *KafkaSinkRecord) GetTopic() string

func (*KafkaSinkRecord) GetValue 

func (m *KafkaSinkRecord) GetValue() []byte

func (*KafkaSinkRecord) ProtoMessage 

func (*KafkaSinkRecord) ProtoMessage()

func (*KafkaSinkRecord) Reset 

func (m *KafkaSinkRecord) Reset()

func (*KafkaSinkRecord) String 

func (m *KafkaSinkRecord) String() string

func (*KafkaSinkRecord) XXX_DiscardUnknown 

func (m *KafkaSinkRecord) XXX_DiscardUnknown()

func (*KafkaSinkRecord) XXX_Marshal 

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

func (*KafkaSinkRecord) XXX_Merge 

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

func (*KafkaSinkRecord) XXX_Size 

func (m *KafkaSinkRecord) XXX_Size() int

func (*KafkaSinkRecord) XXX_Unmarshal 

func (m *KafkaSinkRecord) 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.