Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterReflexServer(s grpc.ServiceRegistrar, srv ReflexServer)
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetForeignId() string
- func (x *Event) GetId() string
- func (x *Event) GetMetadata() []byte
- func (x *Event) GetTimestamp() *timestamppb.Timestamp
- func (x *Event) GetTrace() []byte
- func (x *Event) GetType() int32
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type ReflexClient
- type ReflexServer
- type Reflex_StreamClient
- type Reflex_StreamServer
- type StreamOptions
- func (*StreamOptions) Descriptor() ([]byte, []int)deprecated
- func (x *StreamOptions) GetFromHead() bool
- func (x *StreamOptions) GetLag() *durationpb.Duration
- func (x *StreamOptions) GetToHead() bool
- func (*StreamOptions) ProtoMessage()
- func (x *StreamOptions) ProtoReflect() protoreflect.Message
- func (x *StreamOptions) Reset()
- func (x *StreamOptions) String() string
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamRequest) GetAfter() string
- func (x *StreamRequest) GetOptions() *StreamOptions
- func (*StreamRequest) ProtoMessage()
- func (x *StreamRequest) ProtoReflect() protoreflect.Message
- func (x *StreamRequest) Reset()
- func (x *StreamRequest) String() string
- type Trace
- type UnimplementedReflexServer
- type UnsafeReflexServer
Constants ¶
const (
Reflex_Stream_FullMethodName = "/reflexpb.Reflex/Stream"
)
Variables ¶
var File_reflex_proto protoreflect.FileDescriptor
var Reflex_ServiceDesc = grpc.ServiceDesc{ ServiceName: "reflexpb.Reflex", HandlerType: (*ReflexServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Stream", Handler: _Reflex_Stream_Handler, ServerStreams: true, }, }, Metadata: "reflex.proto", }
Reflex_ServiceDesc is the grpc.ServiceDesc for Reflex service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterReflexServer ¶
func RegisterReflexServer(s grpc.ServiceRegistrar, srv ReflexServer)
Types ¶
type Event ¶
type Event struct { Type int32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` ForeignId string `protobuf:"bytes,5,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"` Id string `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"` Metadata []byte `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"` Trace []byte `protobuf:"bytes,8,opt,name=trace,proto3" json:"trace,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetForeignId ¶
func (*Event) GetMetadata ¶
func (*Event) GetTimestamp ¶
func (x *Event) GetTimestamp() *timestamppb.Timestamp
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type ReflexClient ¶
type ReflexClient interface {
Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (Reflex_StreamClient, error)
}
ReflexClient is the client API for Reflex 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 NewReflexClient ¶
func NewReflexClient(cc grpc.ClientConnInterface) ReflexClient
type ReflexServer ¶
type ReflexServer interface { Stream(*StreamRequest, Reflex_StreamServer) error // contains filtered or unexported methods }
ReflexServer is the server API for Reflex service. All implementations must embed UnimplementedReflexServer for forward compatibility
type Reflex_StreamClient ¶
type Reflex_StreamClient interface { Recv() (*Event, error) grpc.ClientStream }
type Reflex_StreamServer ¶
type Reflex_StreamServer interface { Send(*Event) error grpc.ServerStream }
type StreamOptions ¶
type StreamOptions struct { Lag *durationpb.Duration `protobuf:"bytes,1,opt,name=lag,proto3" json:"lag,omitempty"` FromHead bool `protobuf:"varint,2,opt,name=fromHead,proto3" json:"fromHead,omitempty"` ToHead bool `protobuf:"varint,4,opt,name=toHead,proto3" json:"toHead,omitempty"` // contains filtered or unexported fields }
func (*StreamOptions) Descriptor
deprecated
func (*StreamOptions) Descriptor() ([]byte, []int)
Deprecated: Use StreamOptions.ProtoReflect.Descriptor instead.
func (*StreamOptions) GetFromHead ¶
func (x *StreamOptions) GetFromHead() bool
func (*StreamOptions) GetLag ¶
func (x *StreamOptions) GetLag() *durationpb.Duration
func (*StreamOptions) GetToHead ¶
func (x *StreamOptions) GetToHead() bool
func (*StreamOptions) ProtoMessage ¶
func (*StreamOptions) ProtoMessage()
func (*StreamOptions) ProtoReflect ¶
func (x *StreamOptions) ProtoReflect() protoreflect.Message
func (*StreamOptions) Reset ¶
func (x *StreamOptions) Reset()
func (*StreamOptions) String ¶
func (x *StreamOptions) String() string
type StreamRequest ¶
type StreamRequest struct { Options *StreamOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` After string `protobuf:"bytes,3,opt,name=after,proto3" json:"after,omitempty"` // contains filtered or unexported fields }
func (*StreamRequest) Descriptor
deprecated
func (*StreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.
func (*StreamRequest) GetAfter ¶
func (x *StreamRequest) GetAfter() string
func (*StreamRequest) GetOptions ¶
func (x *StreamRequest) GetOptions() *StreamOptions
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) ProtoReflect ¶
func (x *StreamRequest) ProtoReflect() protoreflect.Message
func (*StreamRequest) Reset ¶
func (x *StreamRequest) Reset()
func (*StreamRequest) String ¶
func (x *StreamRequest) String() string
type Trace ¶
type Trace struct { TraceId string `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` SpanId string `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"` // contains filtered or unexported fields }
func (*Trace) Descriptor
deprecated
func (*Trace) GetTraceId ¶
func (*Trace) ProtoMessage ¶
func (*Trace) ProtoMessage()
func (*Trace) ProtoReflect ¶
func (x *Trace) ProtoReflect() protoreflect.Message
type UnimplementedReflexServer ¶
type UnimplementedReflexServer struct { }
UnimplementedReflexServer must be embedded to have forward compatible implementations.
func (UnimplementedReflexServer) Stream ¶
func (UnimplementedReflexServer) Stream(*StreamRequest, Reflex_StreamServer) error
type UnsafeReflexServer ¶
type UnsafeReflexServer interface {
// contains filtered or unexported methods
}
UnsafeReflexServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReflexServer will result in compilation errors.