log_v1

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 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
View Source 
var Log_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "log.v1.Log",
	HandlerType: (*LogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Produce",
			Handler:    _Log_Produce_Handler,
		},
		{
			MethodName: "Consume",
			Handler:    _Log_Consume_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ConsumeStream",
			Handler:       _Log_ConsumeStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ProduceStream",
			Handler:       _Log_ProduceStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/v1/log.proto",
}

Log_ServiceDesc is the grpc.ServiceDesc for Log service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogServer added in v0.4.1 

func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)

Types

type ConsumeRequest added in v0.4.1 

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

func (*ConsumeRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetOffset added in v0.4.1 

func (x *ConsumeRequest) GetOffset() uint64

func (*ConsumeRequest) ProtoMessage added in v0.4.1 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect added in v0.4.1 

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

func (*ConsumeRequest) Reset added in v0.4.1 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String added in v0.4.1 

func (x *ConsumeRequest) String() string

type ConsumeResponse added in v0.4.1 

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

func (*ConsumeResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetRecord added in v0.4.1 

func (x *ConsumeResponse) GetRecord() *Record

func (*ConsumeResponse) ProtoMessage added in v0.4.1 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect added in v0.4.1 

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

func (*ConsumeResponse) Reset added in v0.4.1 

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) String added in v0.4.1 

func (x *ConsumeResponse) String() string

type ErrOffsetOutOfRange added in v0.4.1 

type ErrOffsetOutOfRange struct {
	Offset uint64
}

func (ErrOffsetOutOfRange) Error added in v0.4.1 

func (e ErrOffsetOutOfRange) Error() string

ErrorOffsetOutOfRange

func (ErrOffsetOutOfRange) GRPCStatus added in v0.4.1 

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

GRPCStatus

type LogClient added in v0.4.1 

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLogClient added in v0.4.1 

func NewLogClient(cc grpc.ClientConnInterface) LogClient

type LogServer added in v0.4.1 

type LogServer interface {
	Produce(context.Context, *ProduceRequest) (*ProduceResponse, error)
	Consume(context.Context, *ConsumeRequest) (*ConsumeResponse, error)
	ConsumeStream(*ConsumeRequest, Log_ConsumeStreamServer) error
	ProduceStream(Log_ProduceStreamServer) error
	// contains filtered or unexported methods
}

LogServer is the server API for Log service. All implementations must embed UnimplementedLogServer for forward compatibility

type Log_ConsumeStreamClient added in v0.4.1 

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

type Log_ConsumeStreamServer added in v0.4.1 

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

type Log_ProduceStreamClient added in v0.4.1 

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

type Log_ProduceStreamServer added in v0.4.1 

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

type ProduceRequest added in v0.4.1 

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

func (*ProduceRequest) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.

func (*ProduceRequest) GetRecord added in v0.4.1 

func (x *ProduceRequest) GetRecord() *Record

func (*ProduceRequest) ProtoMessage added in v0.4.1 

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) ProtoReflect added in v0.4.1 

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

func (*ProduceRequest) Reset added in v0.4.1 

func (x *ProduceRequest) Reset()

func (*ProduceRequest) String added in v0.4.1 

func (x *ProduceRequest) String() string

type ProduceResponse added in v0.4.1 

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

func (*ProduceResponse) Descriptor deprecated added in v0.4.1 

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

Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.

func (*ProduceResponse) GetOffset added in v0.4.1 

func (x *ProduceResponse) GetOffset() uint64

func (*ProduceResponse) ProtoMessage added in v0.4.1 

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) ProtoReflect added in v0.4.1 

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

func (*ProduceResponse) Reset added in v0.4.1 

func (x *ProduceResponse) Reset()

func (*ProduceResponse) String added in v0.4.1 

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

type UnimplementedLogServer struct {
}

UnimplementedLogServer must be embedded to have forward compatible implementations.

func (UnimplementedLogServer) Consume added in v0.4.1 

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

func (UnimplementedLogServer) ConsumeStream added in v0.4.1 

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

func (UnimplementedLogServer) Produce added in v0.4.1 

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

func (UnimplementedLogServer) ProduceStream added in v0.4.1 

func (UnimplementedLogServer) ProduceStream(Log_ProduceStreamServer) error

type UnsafeLogServer added in v0.4.1 

type UnsafeLogServer interface {
	// contains filtered or unexported methods
}

UnsafeLogServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogServer will result in compilation errors.

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.