log_v1

package
v0.0.0-...-ca02700 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_v1_log_proto protoreflect.FileDescriptor

Functions

func RegisterLogServer 

func RegisterLogServer(s *grpc.Server, srv LogServer)

Types

type ConsumeRequest 

type ConsumeRequest struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetOffset 

func (x *ConsumeRequest) GetOffset() uint64

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect 

func (x *ConsumeRequest) ProtoReflect() protoreflect.Message

func (*ConsumeRequest) Reset 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String 

func (x *ConsumeRequest) String() string

type ConsumeResponse 

type ConsumeResponse struct {
	Record *Record `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeResponse) Descriptor deprecated 

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetRecord 

func (x *ConsumeResponse) GetRecord() *Record

func (*ConsumeResponse) ProtoMessage 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect 

func (x *ConsumeResponse) ProtoReflect() protoreflect.Message

func (*ConsumeResponse) Reset 

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) String 

func (x *ConsumeResponse) String() string

type ErrOffsetOutOfRange 

type ErrOffsetOutOfRange struct {
	Offset uint64
}

func (ErrOffsetOutOfRange) Error 

func (e ErrOffsetOutOfRange) Error() string

func (ErrOffsetOutOfRange) GRPCStatus 

func (e ErrOffsetOutOfRange) GRPCStatus() *status.Status

type LogClient 

type LogClient interface {
	Produce(ctx context.Context, in *ProduceRequest, opts ...grpc.CallOption) (*ProduceResponse, error)
	Consume(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (*ConsumeResponse, error)
	ConsumeStream(ctx context.Context, in *ConsumeRequest, opts ...grpc.CallOption) (Log_ConsumeStreamClient, error)
	ProduceStream(ctx context.Context, opts ...grpc.CallOption) (Log_ProduceStreamClient, error)
}

LogClient is the client API for Log service.

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

func NewLogClient 

func NewLogClient(cc grpc.ClientConnInterface) LogClient

type LogServer 

type LogServer interface {
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error
	ProduceStream(Log_ProduceStreamServer) error
}

LogServer is the server API for Log service.

type Log_ConsumeStreamClient 

type Log_ConsumeStreamClient interface {
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type Log_ConsumeStreamServer 

type Log_ConsumeStreamServer interface {
	Send(*ConsumeResponse) error
	grpc.ServerStream
}

type Log_ProduceStreamClient 

type Log_ProduceStreamClient interface {
	Send(*ProduceRequest) error
	Recv() (*ProduceResponse, error)
	grpc.ClientStream
}

type Log_ProduceStreamServer 

type Log_ProduceStreamServer interface {
	Send(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type ProduceRequest 

type ProduceRequest struct {
	Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceRequest) Descriptor deprecated 

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

Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.

func (*ProduceRequest) GetRecord 

func (x *ProduceRequest) GetRecord() *Record

func (*ProduceRequest) ProtoMessage 

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) ProtoReflect 

func (x *ProduceRequest) ProtoReflect() protoreflect.Message

func (*ProduceRequest) Reset 

func (x *ProduceRequest) Reset()

func (*ProduceRequest) String 

func (x *ProduceRequest) String() string

type ProduceResponse 

type ProduceResponse struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceResponse) Descriptor deprecated 

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

Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.

func (*ProduceResponse) GetOffset 

func (x *ProduceResponse) GetOffset() uint64

func (*ProduceResponse) ProtoMessage 

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) ProtoReflect 

func (x *ProduceResponse) ProtoReflect() protoreflect.Message

func (*ProduceResponse) Reset 

func (x *ProduceResponse) Reset()

func (*ProduceResponse) String 

func (x *ProduceResponse) String() string

type Record 

type Record struct {
	Value  []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetOffset 

func (x *Record) GetOffset() uint64

func (*Record) GetValue 

func (x *Record) GetValue() []byte

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type UnimplementedLogServer 

type UnimplementedLogServer struct {
}

UnimplementedLogServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogServer) Consume 

func (*UnimplementedLogServer) Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)

func (*UnimplementedLogServer) ConsumeStream 

func (*UnimplementedLogServer) ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error

func (*UnimplementedLogServer) Produce 

func (*UnimplementedLogServer) Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)

func (*UnimplementedLogServer) ProduceStream 

func (*UnimplementedLogServer) ProduceStream(Log_ProduceStreamServer) 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.