reader_base_go_proto

Documentation

Index

• type ReaderBaseState
  • func (*ReaderBaseState) Descriptor() ([]byte, []int)
  • func (m *ReaderBaseState) GetCurrentWork() []byte
  • func (m *ReaderBaseState) GetNumRecordsProduced() int64
  • func (m *ReaderBaseState) GetWorkFinished() int64
  • func (m *ReaderBaseState) GetWorkStarted() int64
  • func (*ReaderBaseState) ProtoMessage()
  • func (m *ReaderBaseState) Reset()
  • func (m *ReaderBaseState) String() string
  • func (m *ReaderBaseState) XXX_DiscardUnknown()
  • func (m *ReaderBaseState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReaderBaseState) XXX_Merge(src proto.Message)
  • func (m *ReaderBaseState) XXX_Size() int
  • func (m *ReaderBaseState) XXX_Unmarshal(b []byte) error

Types

type ReaderBaseState

type ReaderBaseState struct {
	WorkStarted          int64    `protobuf:"varint,1,opt,name=work_started,json=workStarted,proto3" json:"work_started,omitempty"`
	WorkFinished         int64    `protobuf:"varint,2,opt,name=work_finished,json=workFinished,proto3" json:"work_finished,omitempty"`
	NumRecordsProduced   int64    `protobuf:"varint,3,opt,name=num_records_produced,json=numRecordsProduced,proto3" json:"num_records_produced,omitempty"`
	CurrentWork          []byte   `protobuf:"bytes,4,opt,name=current_work,json=currentWork,proto3" json:"current_work,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For serializing and restoring the state of ReaderBase, see reader_base.h for details.

func (*ReaderBaseState) Descriptor

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

func (*ReaderBaseState) GetCurrentWork

func (m *ReaderBaseState) GetCurrentWork() []byte

func (*ReaderBaseState) GetNumRecordsProduced

func (m *ReaderBaseState) GetNumRecordsProduced() int64

func (*ReaderBaseState) GetWorkFinished

func (m *ReaderBaseState) GetWorkFinished() int64

func (*ReaderBaseState) GetWorkStarted

func (m *ReaderBaseState) GetWorkStarted() int64

func (*ReaderBaseState) ProtoMessage

func (*ReaderBaseState) ProtoMessage()

func (*ReaderBaseState) Reset

func (m *ReaderBaseState) Reset()

func (*ReaderBaseState) String

func (m *ReaderBaseState) String() string

func (*ReaderBaseState) XXX_DiscardUnknown

func (m *ReaderBaseState) XXX_DiscardUnknown()

func (*ReaderBaseState) XXX_Marshal

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

func (*ReaderBaseState) XXX_Merge

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

func (*ReaderBaseState) XXX_Size

func (m *ReaderBaseState) XXX_Size() int

func (*ReaderBaseState) XXX_Unmarshal

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