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) Consume(req *ConsumeRequest, srv LogService_ConsumeServer) error

func (*UnimplementedLogServiceServer) Produce 

func (*UnimplementedLogServiceServer) Produce(srv LogService_ProduceServer) 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.