v1

Oct 16, 2023

Changes in this version

+ const Repeater_LogStream_FullMethodName

+ const Repeater_Stream_FullMethodName

+ var File_repeater_v1_main_proto protoreflect.FileDescriptor

+ var LogLevel_name = map[int32]string

+ var LogLevel_value = map[string]int32

+ var Repeater_ServiceDesc = grpc.ServiceDesc

+ func RegisterRepeaterServer(s grpc.ServiceRegistrar, srv RepeaterServer)

+ type Log struct

+ Level LogLevel

+ Message string

+ Timestamp *timestamppb.Timestamp

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (x *Log) GetLevel() LogLevel

+ func (x *Log) GetMessage() string

+ func (x *Log) GetTimestamp() *timestamppb.Timestamp

+ func (x *Log) ProtoReflect() protoreflect.Message

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type LogLevel int32

+ const LogLevel_DEBUG

+ const LogLevel_ERROR

+ const LogLevel_INFO

+ const LogLevel_WARN

+ func (LogLevel) Descriptor() protoreflect.EnumDescriptor

+ func (LogLevel) EnumDescriptor() ([]byte, []int)

+ func (LogLevel) Type() protoreflect.EnumType

+ func (x LogLevel) Enum() *LogLevel

+ func (x LogLevel) Number() protoreflect.EnumNumber

+ func (x LogLevel) String() string

+ type RepeaterClient interface

+ LogStream func(ctx context.Context, opts ...grpc.CallOption) (Repeater_LogStreamClient, error)

+ Stream func(ctx context.Context, opts ...grpc.CallOption) (Repeater_StreamClient, error)

+ func NewRepeaterClient(cc grpc.ClientConnInterface) RepeaterClient

+ type RepeaterServer interface

+ LogStream func(Repeater_LogStreamServer) error

+ Stream func(Repeater_StreamServer) error

+ type Repeater_LogStreamClient interface

+ Recv func() (*Log, error)

+ Send func(*Log) error

+ type Repeater_LogStreamServer interface

+ Recv func() (*Log, error)

+ Send func(*Log) error

+ type Repeater_StreamClient interface

+ Recv func() (*Request, error)

+ Send func(*Response) error

+ type Repeater_StreamServer interface

+ Recv func() (*Response, error)

+ Send func(*Request) error

+ type Request struct

+ Correlation int64

+ Data []byte

+ Url string

+ func (*Request) Descriptor() ([]byte, []int)

+ func (*Request) ProtoMessage()

+ func (x *Request) GetCorrelation() int64

+ func (x *Request) GetData() []byte

+ func (x *Request) GetUrl() string

+ func (x *Request) ProtoReflect() protoreflect.Message

+ func (x *Request) Reset()

+ func (x *Request) String() string

+ type Response struct

+ Correlation int64

+ Data []byte

+ func (*Response) Descriptor() ([]byte, []int)

+ func (*Response) ProtoMessage()

+ func (x *Response) GetCorrelation() int64

+ func (x *Response) GetData() []byte

+ func (x *Response) ProtoReflect() protoreflect.Message

+ func (x *Response) Reset()

+ func (x *Response) String() string

+ type UnimplementedRepeaterServer struct

+ func (UnimplementedRepeaterServer) LogStream(Repeater_LogStreamServer) error

+ func (UnimplementedRepeaterServer) Stream(Repeater_StreamServer) error

+ type UnsafeRepeaterServer interface