Versions in this module Expand all Collapse all v0 v0.0.2 Feb 10, 2026 v0.0.1 Feb 10, 2026 Changes in this version + const ScopeService_Watch_FullMethodName + var File_scope_v1_scope_proto protoreflect.FileDescriptor + var ScopeService_ServiceDesc = grpc.ServiceDesc + func RegisterScopeServiceServer(s grpc.ServiceRegistrar, srv ScopeServiceServer) + type Caller struct + File string + Function string + Line int32 + func (*Caller) Descriptor() ([]byte, []int) + func (*Caller) ProtoMessage() + func (x *Caller) GetFile() string + func (x *Caller) GetFunction() string + func (x *Caller) GetLine() int32 + func (x *Caller) ProtoReflect() protoreflect.Message + func (x *Caller) Reset() + func (x *Caller) String() string + type QueryEvent struct + Args []string + Callers []*Caller + Duration *durationpb.Duration + Error string + Id string + Op int32 + Query string + RowsAffected int64 + StartTime *timestamppb.Timestamp + TxId string + func (*QueryEvent) Descriptor() ([]byte, []int) + func (*QueryEvent) ProtoMessage() + func (x *QueryEvent) GetArgs() []string + func (x *QueryEvent) GetCallers() []*Caller + func (x *QueryEvent) GetDuration() *durationpb.Duration + func (x *QueryEvent) GetError() string + func (x *QueryEvent) GetId() string + func (x *QueryEvent) GetOp() int32 + func (x *QueryEvent) GetQuery() string + func (x *QueryEvent) GetRowsAffected() int64 + func (x *QueryEvent) GetStartTime() *timestamppb.Timestamp + func (x *QueryEvent) GetTxId() string + func (x *QueryEvent) ProtoReflect() protoreflect.Message + func (x *QueryEvent) Reset() + func (x *QueryEvent) String() string + type ScopeServiceClient interface + Watch func(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WatchResponse], error) + func NewScopeServiceClient(cc grpc.ClientConnInterface) ScopeServiceClient + type ScopeServiceServer interface + Watch func(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error + type ScopeService_WatchClient = grpc.ServerStreamingClient[WatchResponse] + type ScopeService_WatchServer = grpc.ServerStreamingServer[WatchResponse] + type UnimplementedScopeServiceServer struct + func (UnimplementedScopeServiceServer) Watch(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error + type UnsafeScopeServiceServer interface + type WatchRequest struct + func (*WatchRequest) Descriptor() ([]byte, []int) + func (*WatchRequest) ProtoMessage() + func (x *WatchRequest) ProtoReflect() protoreflect.Message + func (x *WatchRequest) Reset() + func (x *WatchRequest) String() string + type WatchResponse struct + Event *QueryEvent + func (*WatchResponse) Descriptor() ([]byte, []int) + func (*WatchResponse) ProtoMessage() + func (x *WatchResponse) GetEvent() *QueryEvent + func (x *WatchResponse) ProtoReflect() protoreflect.Message + func (x *WatchResponse) Reset() + func (x *WatchResponse) String() string
Go to main page