exporter

package
v0.9.15 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2019 License: Apache-2.0 Imports: 24 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")
)
View Source 
var (
	HeavyExporterMethodTiming = stats.Float64(
		"heavy_exporter_method_timing",
		"time spent in exporter method",
		stats.UnitMilliseconds,
	)
)
View Source 
var (
	TagHeavyExporterMethodName = insmetrics.MustTagKey("heavy_exporter_method_name")
)

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 GetTopSyncPulse added in v0.9.1 

type GetTopSyncPulse struct {
}

func (*GetTopSyncPulse) Descriptor added in v0.9.1 

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

func (*GetTopSyncPulse) Equal added in v0.9.1 

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

func (*GetTopSyncPulse) GoString added in v0.9.1 

func (this *GetTopSyncPulse) GoString() string

func (*GetTopSyncPulse) Marshal added in v0.9.1 

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

func (*GetTopSyncPulse) MarshalTo added in v0.9.1 

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

func (*GetTopSyncPulse) ProtoMessage added in v0.9.1 

func (*GetTopSyncPulse) ProtoMessage()

func (*GetTopSyncPulse) Reset added in v0.9.1 

func (m *GetTopSyncPulse) Reset()

func (*GetTopSyncPulse) Size added in v0.9.1 

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

func (*GetTopSyncPulse) String added in v0.9.1 

func (this *GetTopSyncPulse) String() string

func (*GetTopSyncPulse) Unmarshal added in v0.9.1 

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

func (*GetTopSyncPulse) XXX_DiscardUnknown added in v0.9.1 

func (m *GetTopSyncPulse) XXX_DiscardUnknown()

func (*GetTopSyncPulse) XXX_Marshal added in v0.9.1 

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

func (*GetTopSyncPulse) XXX_Merge added in v0.9.1 

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

func (*GetTopSyncPulse) XXX_Size added in v0.9.1 

func (m *GetTopSyncPulse) XXX_Size() int

func (*GetTopSyncPulse) XXX_Unmarshal added in v0.9.1 

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

type OneRequestLimiter added in v0.9.6 

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

func NewOneRequestLimiter added in v0.9.6 

func NewOneRequestLimiter(durationBetweenReq time.Duration) *OneRequestLimiter

func (*OneRequestLimiter) Take added in v0.9.6 

func (l *OneRequestLimiter) Take(ctx context.Context)

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"`
	Nodes          []insolar.Node                                 `protobuf:"bytes,23,rep,name=Nodes,proto3" json:"Nodes"`
}

func (*Pulse) Descriptor 

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

func (*Pulse) Equal 

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

func (*Pulse) GetNodes added in v0.9.5 

func (m *Pulse) GetNodes() []insolar.Node

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)
	TopSyncPulse(ctx context.Context, in *GetTopSyncPulse, opts ...grpc.CallOption) (*TopSyncPulseResponse, 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
	TopSyncPulse(context.Context, *GetTopSyncPulse) (*TopSyncPulseResponse, 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 insolarPulse.Calculator, jetKeeper executor.JetKeeper, nodeAccessor node.Accessor) *PulseServer

func (*PulseServer) Export 

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

func (*PulseServer) TopSyncPulse added in v0.9.1 

func (p *PulseServer) TopSyncPulse(ctx context.Context, _ *GetTopSyncPulse) (*TopSyncPulseResponse, 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"`
	ShouldIterateFrom *github_com_insolar_insolar_insolar.PulseNumber `` /* 146-byte string literal not displayed */
}

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 insolarPulse.Calculator,
	recordIndex object.RecordPositionAccessor,
	recordAccessor object.RecordAccessor,
	jetKeeper executor.JetKeeper,
	limiter *OneRequestLimiter,
) *RecordServer

func (*RecordServer) Export 

func (r *RecordServer) Export(getRecords *GetRecords, stream RecordExporter_ExportServer) error

type TopSyncPulseResponse added in v0.9.1 

type TopSyncPulseResponse struct {
	Polymorph   uint32 `protobuf:"varint,16,opt,name=Polymorph,proto3" json:"Polymorph,omitempty"`
	PulseNumber uint32 `protobuf:"varint,20,opt,name=PulseNumber,proto3" json:"PulseNumber,omitempty"`
}

func (*TopSyncPulseResponse) Descriptor added in v0.9.1 

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

func (*TopSyncPulseResponse) Equal added in v0.9.1 

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

func (*TopSyncPulseResponse) GetPolymorph added in v0.9.1 

func (m *TopSyncPulseResponse) GetPolymorph() uint32

func (*TopSyncPulseResponse) GetPulseNumber added in v0.9.1 

func (m *TopSyncPulseResponse) GetPulseNumber() uint32

func (*TopSyncPulseResponse) GoString added in v0.9.1 

func (this *TopSyncPulseResponse) GoString() string

func (*TopSyncPulseResponse) Marshal added in v0.9.1 

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

func (*TopSyncPulseResponse) MarshalTo added in v0.9.1 

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

func (*TopSyncPulseResponse) ProtoMessage added in v0.9.1 

func (*TopSyncPulseResponse) ProtoMessage()

func (*TopSyncPulseResponse) Reset added in v0.9.1 

func (m *TopSyncPulseResponse) Reset()

func (*TopSyncPulseResponse) Size added in v0.9.1 

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

func (*TopSyncPulseResponse) String added in v0.9.1 

func (this *TopSyncPulseResponse) String() string

func (*TopSyncPulseResponse) Unmarshal added in v0.9.1 

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

func (*TopSyncPulseResponse) XXX_DiscardUnknown added in v0.9.1 

func (m *TopSyncPulseResponse) XXX_DiscardUnknown()

func (*TopSyncPulseResponse) XXX_Marshal added in v0.9.1 

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

func (*TopSyncPulseResponse) XXX_Merge added in v0.9.1 

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

func (*TopSyncPulseResponse) XXX_Size added in v0.9.1 

func (m *TopSyncPulseResponse) XXX_Size() int

func (*TopSyncPulseResponse) XXX_Unmarshal added in v0.9.1 

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