exporter

package
v0.9.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Aug 20, 2019 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPulseExporter = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPulseExporter   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRecordExporter = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRecordExporter   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterPulseExporterServer 

func RegisterPulseExporterServer(s *grpc.Server, srv PulseExporterServer)

func RegisterRecordExporterServer 

func RegisterRecordExporterServer(s *grpc.Server, srv RecordExporterServer)

Types

type GetPulses 

type GetPulses struct {
	Polymorph   uint32                                         `protobuf:"varint,16,opt,name=Polymorph,proto3" json:"Polymorph,omitempty"`
	PulseNumber github_com_insolar_insolar_insolar.PulseNumber `protobuf:"bytes,20,opt,name=PulseNumber,proto3,customtype=github.com/insolar/insolar/insolar.PulseNumber" json:"PulseNumber"`
	Count       uint32                                         `protobuf:"varint,22,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*GetPulses) Descriptor 

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

func (*GetPulses) Equal 

func (this *GetPulses) Equal(that interface{}) bool

func (*GetPulses) GetCount 

func (m *GetPulses) GetCount() uint32

func (*GetPulses) GetPolymorph 

func (m *GetPulses) GetPolymorph() uint32

func (*GetPulses) GoString 

func (this *GetPulses) GoString() string

func (*GetPulses) Marshal 

func (m *GetPulses) Marshal() (dAtA []byte, err error)

func (*GetPulses) MarshalTo 

func (m *GetPulses) MarshalTo(dAtA []byte) (int, error)

func (*GetPulses) ProtoMessage 

func (*GetPulses) ProtoMessage()

func (*GetPulses) Reset 

func (m *GetPulses) Reset()

func (*GetPulses) Size 

func (m *GetPulses) Size() (n int)

func (*GetPulses) String 

func (this *GetPulses) String() string

func (*GetPulses) Unmarshal 

func (m *GetPulses) Unmarshal(dAtA []byte) error

func (*GetPulses) XXX_DiscardUnknown 

func (m *GetPulses) XXX_DiscardUnknown()

func (*GetPulses) XXX_Marshal 

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

func (*GetPulses) XXX_Merge 

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

func (*GetPulses) XXX_Size 

func (m *GetPulses) XXX_Size() int

func (*GetPulses) XXX_Unmarshal 

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

type GetRecords 

type GetRecords struct {
	Polymorph    uint32                                         `protobuf:"varint,16,opt,name=Polymorph,proto3" json:"Polymorph,omitempty"`
	PulseNumber  github_com_insolar_insolar_insolar.PulseNumber `protobuf:"bytes,20,opt,name=PulseNumber,proto3,customtype=github.com/insolar/insolar/insolar.PulseNumber" json:"PulseNumber"`
	RecordNumber uint32                                         `protobuf:"varint,21,opt,name=RecordNumber,proto3" json:"RecordNumber,omitempty"`
	Count        uint32                                         `protobuf:"varint,22,opt,name=Count,proto3" json:"Count,omitempty"`
}

func (*GetRecords) Descriptor 

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

func (*GetRecords) Equal 

func (this *GetRecords) Equal(that interface{}) bool

func (*GetRecords) GetCount 

func (m *GetRecords) GetCount() uint32

func (*GetRecords) GetPolymorph 

func (m *GetRecords) GetPolymorph() uint32

func (*GetRecords) GetRecordNumber 

func (m *GetRecords) GetRecordNumber() uint32

func (*GetRecords) GoString 

func (this *GetRecords) GoString() string

func (*GetRecords) Marshal 

func (m *GetRecords) Marshal() (dAtA []byte, err error)

func (*GetRecords) MarshalTo 

func (m *GetRecords) MarshalTo(dAtA []byte) (int, error)

func (*GetRecords) ProtoMessage 

func (*GetRecords) ProtoMessage()

func (*GetRecords) Reset 

func (m *GetRecords) Reset()

func (*GetRecords) Size 

func (m *GetRecords) Size() (n int)

func (*GetRecords) String 

func (this *GetRecords) String() string

func (*GetRecords) Unmarshal 

func (m *GetRecords) Unmarshal(dAtA []byte) error

func (*GetRecords) XXX_DiscardUnknown 

func (m *GetRecords) XXX_DiscardUnknown()

func (*GetRecords) XXX_Marshal 

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

func (*GetRecords) XXX_Merge 

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

func (*GetRecords) XXX_Size 

func (m *GetRecords) XXX_Size() int

func (*GetRecords) XXX_Unmarshal 

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

type Pulse 

type Pulse struct {
	Polymorph      uint32                                         `protobuf:"varint,16,opt,name=Polymorph,proto3" json:"Polymorph,omitempty"`
	PulseNumber    github_com_insolar_insolar_insolar.PulseNumber `protobuf:"bytes,20,opt,name=PulseNumber,proto3,customtype=github.com/insolar/insolar/insolar.PulseNumber" json:"PulseNumber"`
	Entropy        github_com_insolar_insolar_insolar.Entropy     `protobuf:"bytes,21,opt,name=Entropy,proto3,customtype=github.com/insolar/insolar/insolar.Entropy" json:"Entropy"`
	PulseTimestamp int64                                          `protobuf:"varint,22,opt,name=PulseTimestamp,proto3" json:"PulseTimestamp,omitempty"`
}

func (*Pulse) Descriptor 

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

func (*Pulse) Equal 

func (this *Pulse) Equal(that interface{}) bool

func (*Pulse) GetPolymorph 

func (m *Pulse) GetPolymorph() uint32

func (*Pulse) GetPulseTimestamp 

func (m *Pulse) GetPulseTimestamp() int64

func (*Pulse) GoString 

func (this *Pulse) GoString() string

func (*Pulse) Marshal 

func (m *Pulse) Marshal() (dAtA []byte, err error)

func (*Pulse) MarshalTo 

func (m *Pulse) MarshalTo(dAtA []byte) (int, error)

func (*Pulse) ProtoMessage 

func (*Pulse) ProtoMessage()

func (*Pulse) Reset 

func (m *Pulse) Reset()

func (*Pulse) Size 

func (m *Pulse) Size() (n int)

func (*Pulse) String 

func (this *Pulse) String() string

func (*Pulse) Unmarshal 

func (m *Pulse) Unmarshal(dAtA []byte) error

func (*Pulse) XXX_DiscardUnknown 

func (m *Pulse) XXX_DiscardUnknown()

func (*Pulse) XXX_Marshal 

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

func (*Pulse) XXX_Merge 

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

func (*Pulse) XXX_Size 

func (m *Pulse) XXX_Size() int

func (*Pulse) XXX_Unmarshal 

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

type PulseExporterClient 

type PulseExporterClient interface {
	Export(ctx context.Context, in *GetPulses, opts ...grpc.CallOption) (PulseExporter_ExportClient, error)
}

PulseExporterClient is the client API for PulseExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPulseExporterClient 

func NewPulseExporterClient(cc *grpc.ClientConn) PulseExporterClient

type PulseExporterServer 

type PulseExporterServer interface {
	Export(*GetPulses, PulseExporter_ExportServer) error
}

PulseExporterServer is the server API for PulseExporter service.

type PulseExporter_ExportClient 

type PulseExporter_ExportClient interface {
	Recv() (*Pulse, error)
	grpc.ClientStream
}

type PulseExporter_ExportServer 

type PulseExporter_ExportServer interface {
	Send(*Pulse) error
	grpc.ServerStream
}

type PulseServer 

type PulseServer struct {
	// contains filtered or unexported fields
}

func NewPulseServer 

func NewPulseServer(pulses pulse.Calculator, jetKeeper executor.JetKeeper) *PulseServer

func (*PulseServer) Export 

func (p *PulseServer) Export(getPulses *GetPulses, stream PulseExporter_ExportServer) error

type Record 

type Record struct {
	Polymorph    uint32          `protobuf:"varint,16,opt,name=Polymorph,proto3" json:"Polymorph,omitempty"`
	RecordNumber uint32          `protobuf:"varint,20,opt,name=RecordNumber,proto3" json:"RecordNumber,omitempty"`
	Record       record.Material `protobuf:"bytes,21,opt,name=Record,proto3" json:"Record"`
}

func (*Record) Descriptor 

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

func (*Record) Equal 

func (this *Record) Equal(that interface{}) bool

func (*Record) GetPolymorph 

func (m *Record) GetPolymorph() uint32

func (*Record) GetRecord 

func (m *Record) GetRecord() record.Material

func (*Record) GetRecordNumber 

func (m *Record) GetRecordNumber() uint32

func (*Record) GoString 

func (this *Record) GoString() string

func (*Record) Marshal 

func (m *Record) Marshal() (dAtA []byte, err error)

func (*Record) MarshalTo 

func (m *Record) MarshalTo(dAtA []byte) (int, error)

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) Size 

func (m *Record) Size() (n int)

func (*Record) String 

func (this *Record) String() string

func (*Record) Unmarshal 

func (m *Record) Unmarshal(dAtA []byte) error

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

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

func (*Record) XXX_Merge 

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

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

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

type RecordExporterClient 

type RecordExporterClient interface {
	Export(ctx context.Context, in *GetRecords, opts ...grpc.CallOption) (RecordExporter_ExportClient, error)
}

RecordExporterClient is the client API for RecordExporter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRecordExporterClient 

func NewRecordExporterClient(cc *grpc.ClientConn) RecordExporterClient

type RecordExporterServer 

type RecordExporterServer interface {
	Export(*GetRecords, RecordExporter_ExportServer) error
}

RecordExporterServer is the server API for RecordExporter service.

type RecordExporter_ExportClient 

type RecordExporter_ExportClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type RecordExporter_ExportServer 

type RecordExporter_ExportServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type RecordServer 

type RecordServer struct {
	// contains filtered or unexported fields
}

func NewRecordServer 

func NewRecordServer(
	pulseCalculator pulse.Calculator,
	recordIndex object.RecordPositionAccessor,
	recordAccessor object.RecordAccessor,
	jetKeeper executor.JetKeeper,
) *RecordServer

func (*RecordServer) Export 

func (r *RecordServer) Export(getRecords *GetRecords, stream RecordExporter_ExportServer) 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.