exporter

package
v1.0.10-0...-7349ede Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2023 License: MIT Imports: 20 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")
	ErrUnexpectedEndOfGroupPulseExporter = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRecordExporter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRecordExporter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRecordExporter = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPulseExporterServer 

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

func RegisterRecordExporterServer 

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

Types

type GetNextPulseRequest 

type GetNextPulseRequest struct {
	PulseNumberFrom int64    `protobuf:"varint,1,opt,name=PulseNumberFrom,proto3" json:"PulseNumberFrom,omitempty"`
	Prototypes      [][]byte `protobuf:"bytes,2,rep,name=Prototypes,proto3" json:"Prototypes,omitempty"`
}

func (*GetNextPulseRequest) Descriptor 

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

func (*GetNextPulseRequest) Equal 

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

func (*GetNextPulseRequest) GetPrototypes 

func (m *GetNextPulseRequest) GetPrototypes() [][]byte

func (*GetNextPulseRequest) GetPulseNumberFrom 

func (m *GetNextPulseRequest) GetPulseNumberFrom() int64

func (*GetNextPulseRequest) GoString 

func (this *GetNextPulseRequest) GoString() string

func (*GetNextPulseRequest) Marshal 

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

func (*GetNextPulseRequest) MarshalTo 

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

func (*GetNextPulseRequest) MarshalToSizedBuffer 

func (m *GetNextPulseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNextPulseRequest) ProtoMessage 

func (*GetNextPulseRequest) ProtoMessage()

func (*GetNextPulseRequest) Reset 

func (m *GetNextPulseRequest) Reset()

func (*GetNextPulseRequest) Size 

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

func (*GetNextPulseRequest) String 

func (this *GetNextPulseRequest) String() string

func (*GetNextPulseRequest) Unmarshal 

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

func (*GetNextPulseRequest) XXX_DiscardUnknown 

func (m *GetNextPulseRequest) XXX_DiscardUnknown()

func (*GetNextPulseRequest) XXX_Marshal 

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

func (*GetNextPulseRequest) XXX_Merge 

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

func (*GetNextPulseRequest) XXX_Size 

func (m *GetNextPulseRequest) XXX_Size() int

func (*GetNextPulseRequest) XXX_Unmarshal 

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

type GetNextPulseResponse 

type GetNextPulseResponse struct {
	PulseNumber     int64 `protobuf:"varint,1,opt,name=PulseNumber,proto3" json:"PulseNumber,omitempty"`
	PrevPulseNumber int64 `protobuf:"varint,2,opt,name=PrevPulseNumber,proto3" json:"PrevPulseNumber,omitempty"`
	RecordAmount    int64 `protobuf:"varint,3,opt,name=RecordAmount,proto3" json:"RecordAmount,omitempty"`
}

func (*GetNextPulseResponse) Descriptor 

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

func (*GetNextPulseResponse) Equal 

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

func (*GetNextPulseResponse) GetPrevPulseNumber 

func (m *GetNextPulseResponse) GetPrevPulseNumber() int64

func (*GetNextPulseResponse) GetPulseNumber 

func (m *GetNextPulseResponse) GetPulseNumber() int64

func (*GetNextPulseResponse) GetRecordAmount 

func (m *GetNextPulseResponse) GetRecordAmount() int64

func (*GetNextPulseResponse) GoString 

func (this *GetNextPulseResponse) GoString() string

func (*GetNextPulseResponse) Marshal 

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

func (*GetNextPulseResponse) MarshalTo 

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

func (*GetNextPulseResponse) MarshalToSizedBuffer 

func (m *GetNextPulseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNextPulseResponse) ProtoMessage 

func (*GetNextPulseResponse) ProtoMessage()

func (*GetNextPulseResponse) Reset 

func (m *GetNextPulseResponse) Reset()

func (*GetNextPulseResponse) Size 

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

func (*GetNextPulseResponse) String 

func (this *GetNextPulseResponse) String() string

func (*GetNextPulseResponse) Unmarshal 

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

func (*GetNextPulseResponse) XXX_DiscardUnknown 

func (m *GetNextPulseResponse) XXX_DiscardUnknown()

func (*GetNextPulseResponse) XXX_Marshal 

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

func (*GetNextPulseResponse) XXX_Merge 

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

func (*GetNextPulseResponse) XXX_Size 

func (m *GetNextPulseResponse) XXX_Size() int

func (*GetNextPulseResponse) XXX_Unmarshal 

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

type GetRecordsRequest 

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

func (*GetRecordsRequest) Descriptor 

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

func (*GetRecordsRequest) Equal 

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

func (*GetRecordsRequest) GetPolymorph 

func (m *GetRecordsRequest) GetPolymorph() uint32

func (*GetRecordsRequest) GoString 

func (this *GetRecordsRequest) GoString() string

func (*GetRecordsRequest) Marshal 

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

func (*GetRecordsRequest) MarshalTo 

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

func (*GetRecordsRequest) MarshalToSizedBuffer 

func (m *GetRecordsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsRequest) ProtoMessage 

func (*GetRecordsRequest) ProtoMessage()

func (*GetRecordsRequest) Reset 

func (m *GetRecordsRequest) Reset()

func (*GetRecordsRequest) Size 

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

func (*GetRecordsRequest) String 

func (this *GetRecordsRequest) String() string

func (*GetRecordsRequest) Unmarshal 

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

func (*GetRecordsRequest) XXX_DiscardUnknown 

func (m *GetRecordsRequest) XXX_DiscardUnknown()

func (*GetRecordsRequest) XXX_Marshal 

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

func (*GetRecordsRequest) XXX_Merge 

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

func (*GetRecordsRequest) XXX_Size 

func (m *GetRecordsRequest) XXX_Size() int

func (*GetRecordsRequest) XXX_Unmarshal 

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

type GetRecordsResponse 

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

func (*GetRecordsResponse) Descriptor 

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

func (*GetRecordsResponse) Equal 

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

func (*GetRecordsResponse) GetPolymorph 

func (m *GetRecordsResponse) GetPolymorph() uint32

func (*GetRecordsResponse) GoString 

func (this *GetRecordsResponse) GoString() string

func (*GetRecordsResponse) Marshal 

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

func (*GetRecordsResponse) MarshalTo 

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

func (*GetRecordsResponse) MarshalToSizedBuffer 

func (m *GetRecordsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRecordsResponse) ProtoMessage 

func (*GetRecordsResponse) ProtoMessage()

func (*GetRecordsResponse) Reset 

func (m *GetRecordsResponse) Reset()

func (*GetRecordsResponse) Size 

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

func (*GetRecordsResponse) String 

func (this *GetRecordsResponse) String() string

func (*GetRecordsResponse) Unmarshal 

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

func (*GetRecordsResponse) XXX_DiscardUnknown 

func (m *GetRecordsResponse) XXX_DiscardUnknown()

func (*GetRecordsResponse) XXX_Marshal 

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

func (*GetRecordsResponse) XXX_Merge 

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

func (*GetRecordsResponse) XXX_Size 

func (m *GetRecordsResponse) XXX_Size() int

func (*GetRecordsResponse) XXX_Unmarshal 

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

type PulseExporterClient 

type PulseExporterClient interface {
	GetNextPulse(ctx context.Context, in *GetNextPulseRequest, opts ...grpc.CallOption) (PulseExporter_GetNextPulseClient, 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 {
	GetNextPulse(*GetNextPulseRequest, PulseExporter_GetNextPulseServer) error
}

PulseExporterServer is the server API for PulseExporter service.

type PulseExporter_GetNextPulseClient 

type PulseExporter_GetNextPulseClient interface {
	Recv() (*GetNextPulseResponse, error)
	grpc.ClientStream
}

type PulseExporter_GetNextPulseServer 

type PulseExporter_GetNextPulseServer interface {
	Send(*GetNextPulseResponse) error
	grpc.ServerStream
}

type PulseServer 

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

func NewPulseServer 

func NewPulseServer(repo interfaces.Storage, pulsePeriod time.Duration, logger *log.Logger) *PulseServer

func (*PulseServer) GetNextPulse 

func (s *PulseServer) GetNextPulse(req *GetNextPulseRequest, stream PulseExporter_GetNextPulseServer) error

type RecordExporterClient 

type RecordExporterClient interface {
	GetRecords(ctx context.Context, in *GetRecordsRequest, opts ...grpc.CallOption) (RecordExporter_GetRecordsClient, 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 {
	GetRecords(*GetRecordsRequest, RecordExporter_GetRecordsServer) error
}

RecordExporterServer is the server API for RecordExporter service.

type RecordExporter_GetRecordsClient 

type RecordExporter_GetRecordsClient interface {
	Recv() (*GetRecordsResponse, error)
	grpc.ClientStream
}

type RecordExporter_GetRecordsServer 

type RecordExporter_GetRecordsServer interface {
	Send(*GetRecordsResponse) error
	grpc.ServerStream
}

type RecordServer 

type RecordServer struct {
}

func NewRecordServer 

func NewRecordServer() *RecordServer

func (*RecordServer) GetRecords 

func (s *RecordServer) GetRecords(*GetRecordsRequest, RecordExporter_GetRecordsServer) error

type Server 

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

Server implements introspection gRPC server.

func NewServer 

func NewServer(listen string, grpcServer *grpc.Server) *Server

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop 

func (s *Server) Stop(ctx context.Context) error

type UnimplementedPulseExporterServer 

type UnimplementedPulseExporterServer struct {
}

UnimplementedPulseExporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedPulseExporterServer) GetNextPulse 

func (*UnimplementedPulseExporterServer) GetNextPulse(req *GetNextPulseRequest, srv PulseExporter_GetNextPulseServer) error

type UnimplementedRecordExporterServer 

type UnimplementedRecordExporterServer struct {
}

UnimplementedRecordExporterServer can be embedded to have forward compatible implementations.

func (*UnimplementedRecordExporterServer) GetRecords 

func (*UnimplementedRecordExporterServer) GetRecords(req *GetRecordsRequest, srv RecordExporter_GetRecordsServer) 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.