log

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthLog        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLog          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLog = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLogServiceServer

func RegisterLogServiceServer(s *grpc.Server, srv LogServiceServer)

Types

type ConsumeRequest

type ConsumeRequest struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*ConsumeRequest) Descriptor

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

func (*ConsumeRequest) GetOffset

func (m *ConsumeRequest) GetOffset() uint64

func (*ConsumeRequest) Marshal

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

func (*ConsumeRequest) MarshalTo

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

func (*ConsumeRequest) MarshalToSizedBuffer

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

func (*ConsumeRequest) ProtoMessage

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) Reset

func (m *ConsumeRequest) Reset()

func (*ConsumeRequest) Size

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

func (*ConsumeRequest) String

func (m *ConsumeRequest) String() string

func (*ConsumeRequest) Unmarshal

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

func (*ConsumeRequest) XXX_DiscardUnknown

func (m *ConsumeRequest) XXX_DiscardUnknown()

func (*ConsumeRequest) XXX_Marshal

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

func (*ConsumeRequest) XXX_Merge

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

func (*ConsumeRequest) XXX_Size

func (m *ConsumeRequest) XXX_Size() int

func (*ConsumeRequest) XXX_Unmarshal

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

type LogRecord

type LogRecord struct {
	Offset    uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*LogRecord) Descriptor

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

func (*LogRecord) GetOffset

func (m *LogRecord) GetOffset() uint64

func (*LogRecord) GetTimestamp

func (m *LogRecord) GetTimestamp() uint64

func (*LogRecord) GetValue

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

func (*LogRecord) Marshal

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

func (*LogRecord) MarshalTo

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

func (*LogRecord) MarshalToSizedBuffer

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

func (*LogRecord) ProtoMessage

func (*LogRecord) ProtoMessage()

func (*LogRecord) Reset

func (m *LogRecord) Reset()

func (*LogRecord) Size

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

func (*LogRecord) String

func (m *LogRecord) String() string

func (*LogRecord) Unmarshal

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

func (*LogRecord) XXX_DiscardUnknown

func (m *LogRecord) XXX_DiscardUnknown()

func (*LogRecord) XXX_Marshal

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

func (*LogRecord) XXX_Merge

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

func (*LogRecord) XXX_Size

func (m *LogRecord) XXX_Size() int

func (*LogRecord) XXX_Unmarshal

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

type LogServiceClient

type LogServiceClient interface {
	Produce(ctx context.Context, opts ...grpc.CallOption) (LogService_ProduceClient, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (LogService_ConsumeClient, error)
}

LogServiceClient is the client API for LogService service.

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

func NewLogServiceClient

func NewLogServiceClient(cc *grpc.ClientConn) LogServiceClient

type LogServiceServer

type LogServiceServer interface {
	Produce(LogService_ProduceServer) error
	Consume(*ConsumeRequest, LogService_ConsumeServer) error
}

LogServiceServer is the server API for LogService service.

type LogService_ConsumeClient

type LogService_ConsumeClient interface {
	Recv() (*LogRecord, error)
	grpc.ClientStream
}

type LogService_ConsumeServer

type LogService_ConsumeServer interface {
	Send(*LogRecord) error
	grpc.ServerStream
}

type LogService_ProduceClient

type LogService_ProduceClient interface {
	Send(*ProduceRequest) error
	CloseAndRecv() (*ProduceResponse, error)
	grpc.ClientStream
}

type LogService_ProduceServer

type LogService_ProduceServer interface {
	SendAndClose(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type ProduceRequest

type ProduceRequest struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ProduceRequest) Descriptor

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

func (*ProduceRequest) GetValue

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

func (*ProduceRequest) Marshal

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

func (*ProduceRequest) MarshalTo

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

func (*ProduceRequest) MarshalToSizedBuffer

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

func (*ProduceRequest) ProtoMessage

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) Reset

func (m *ProduceRequest) Reset()

func (*ProduceRequest) Size

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

func (*ProduceRequest) String

func (m *ProduceRequest) String() string

func (*ProduceRequest) Unmarshal

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

func (*ProduceRequest) XXX_DiscardUnknown

func (m *ProduceRequest) XXX_DiscardUnknown()

func (*ProduceRequest) XXX_Marshal

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

func (*ProduceRequest) XXX_Merge

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

func (*ProduceRequest) XXX_Size

func (m *ProduceRequest) XXX_Size() int

func (*ProduceRequest) XXX_Unmarshal

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

type ProduceResponse

type ProduceResponse struct {
}

func (*ProduceResponse) Descriptor

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

func (*ProduceResponse) Marshal

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

func (*ProduceResponse) MarshalTo

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

func (*ProduceResponse) MarshalToSizedBuffer

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

func (*ProduceResponse) ProtoMessage

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) Reset

func (m *ProduceResponse) Reset()

func (*ProduceResponse) Size

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

func (*ProduceResponse) String

func (m *ProduceResponse) String() string

func (*ProduceResponse) Unmarshal

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

func (*ProduceResponse) XXX_DiscardUnknown

func (m *ProduceResponse) XXX_DiscardUnknown()

func (*ProduceResponse) XXX_Marshal

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

func (*ProduceResponse) XXX_Merge

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

func (*ProduceResponse) XXX_Size

func (m *ProduceResponse) XXX_Size() int

func (*ProduceResponse) XXX_Unmarshal

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

type UnimplementedLogServiceServer

type UnimplementedLogServiceServer struct {
}

UnimplementedLogServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogServiceServer) Consume

func (*UnimplementedLogServiceServer) Produce

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL