Documentation ¶
Index ¶
- Variables
- func RegisterObserverServiceServer(s grpc.ServiceRegistrar, srv ObserverServiceServer)
- func RegisterSnoozeThisLogServiceServer(s grpc.ServiceRegistrar, srv SnoozeThisLogServiceServer)
- type Filter
- type Observable
- func (*Observable) Descriptor() ([]byte, []int)deprecated
- func (x *Observable) GetFilters() []*Filter
- func (x *Observable) GetId() string
- func (x *Observable) GetSignature() string
- func (*Observable) ProtoMessage()
- func (x *Observable) ProtoReflect() protoreflect.Message
- func (x *Observable) Reset()
- func (x *Observable) String() string
- type ObserverServiceClient
- type ObserverServiceServer
- type ObserverService_CommunicateClient
- type ObserverService_CommunicateServer
- type ObserverToScanner
- func (*ObserverToScanner) Descriptor() ([]byte, []int)deprecated
- func (x *ObserverToScanner) GetCancelObservable() string
- func (m *ObserverToScanner) GetMsg() isObserverToScanner_Msg
- func (x *ObserverToScanner) GetNewObservable() *Observable
- func (x *ObserverToScanner) GetRegister() *RegisterScannerResponse
- func (x *ObserverToScanner) GetTestFilters() *TestFiltersRequest
- func (*ObserverToScanner) ProtoMessage()
- func (x *ObserverToScanner) ProtoReflect() protoreflect.Message
- func (x *ObserverToScanner) Reset()
- func (x *ObserverToScanner) String() string
- type ObserverToScanner_CancelObservable
- type ObserverToScanner_NewObservable
- type ObserverToScanner_Register
- type ObserverToScanner_TestFilters
- type ObserverToSnoozeThis
- func (*ObserverToSnoozeThis) Descriptor() ([]byte, []int)deprecated
- func (m *ObserverToSnoozeThis) GetMsg() isObserverToSnoozeThis_Msg
- func (x *ObserverToSnoozeThis) GetObservedObservable() string
- func (x *ObserverToSnoozeThis) GetRegister() *RegisterObserverRequest
- func (x *ObserverToSnoozeThis) GetRejectObservable() *RejectObservable
- func (*ObserverToSnoozeThis) ProtoMessage()
- func (x *ObserverToSnoozeThis) ProtoReflect() protoreflect.Message
- func (x *ObserverToSnoozeThis) Reset()
- func (x *ObserverToSnoozeThis) String() string
- type ObserverToSnoozeThis_ObservedObservable
- type ObserverToSnoozeThis_Register
- type ObserverToSnoozeThis_RejectObservable
- type RegisterObserverRequest
- func (*RegisterObserverRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterObserverRequest) GetLogInstanceToken() string
- func (x *RegisterObserverRequest) GetObserverProtocolVersion() int32
- func (*RegisterObserverRequest) ProtoMessage()
- func (x *RegisterObserverRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterObserverRequest) Reset()
- func (x *RegisterObserverRequest) String() string
- type RegisterObserverResponse
- func (*RegisterObserverResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterObserverResponse) GetActiveObservables() []*Observable
- func (x *RegisterObserverResponse) GetRegisteredUrl() string
- func (*RegisterObserverResponse) ProtoMessage()
- func (x *RegisterObserverResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterObserverResponse) Reset()
- func (x *RegisterObserverResponse) String() string
- type RegisterScannerRequest
- func (*RegisterScannerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterScannerRequest) GetScannerType() string
- func (*RegisterScannerRequest) ProtoMessage()
- func (x *RegisterScannerRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterScannerRequest) Reset()
- func (x *RegisterScannerRequest) String() string
- type RegisterScannerResponse
- func (*RegisterScannerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterScannerResponse) GetActiveObservables() []*Observable
- func (*RegisterScannerResponse) ProtoMessage()
- func (x *RegisterScannerResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterScannerResponse) Reset()
- func (x *RegisterScannerResponse) String() string
- type RejectObservable
- func (*RejectObservable) Descriptor() ([]byte, []int)deprecated
- func (x *RejectObservable) GetId() string
- func (x *RejectObservable) GetMessage() string
- func (*RejectObservable) ProtoMessage()
- func (x *RejectObservable) ProtoReflect() protoreflect.Message
- func (x *RejectObservable) Reset()
- func (x *RejectObservable) String() string
- type ScannerToObserver
- func (*ScannerToObserver) Descriptor() ([]byte, []int)deprecated
- func (m *ScannerToObserver) GetMsg() isScannerToObserver_Msg
- func (x *ScannerToObserver) GetObservedObservable() string
- func (x *ScannerToObserver) GetRegister() *RegisterScannerRequest
- func (x *ScannerToObserver) GetRejectObservable() *RejectObservable
- func (x *ScannerToObserver) GetTestFilters() *TestFiltersResponse
- func (x *ScannerToObserver) GetUpdateFields() *UpdateFields
- func (*ScannerToObserver) ProtoMessage()
- func (x *ScannerToObserver) ProtoReflect() protoreflect.Message
- func (x *ScannerToObserver) Reset()
- func (x *ScannerToObserver) String() string
- type ScannerToObserver_ObservedObservable
- type ScannerToObserver_Register
- type ScannerToObserver_RejectObservable
- type ScannerToObserver_TestFilters
- type ScannerToObserver_UpdateFields
- type SnoozeThisLogServiceClient
- type SnoozeThisLogServiceServer
- type SnoozeThisLogService_CommunicateClient
- type SnoozeThisLogService_CommunicateServer
- type SnoozeThisToObserver
- func (*SnoozeThisToObserver) Descriptor() ([]byte, []int)deprecated
- func (x *SnoozeThisToObserver) GetCancelObservable() string
- func (m *SnoozeThisToObserver) GetMsg() isSnoozeThisToObserver_Msg
- func (x *SnoozeThisToObserver) GetNewObservable() *Observable
- func (x *SnoozeThisToObserver) GetRegister() *RegisterObserverResponse
- func (*SnoozeThisToObserver) ProtoMessage()
- func (x *SnoozeThisToObserver) ProtoReflect() protoreflect.Message
- func (x *SnoozeThisToObserver) Reset()
- func (x *SnoozeThisToObserver) String() string
- type SnoozeThisToObserver_CancelObservable
- type SnoozeThisToObserver_NewObservable
- type SnoozeThisToObserver_Register
- type TestFiltersRequest
- func (*TestFiltersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TestFiltersRequest) GetFilters() []*Filter
- func (x *TestFiltersRequest) GetTestId() int64
- func (*TestFiltersRequest) ProtoMessage()
- func (x *TestFiltersRequest) ProtoReflect() protoreflect.Message
- func (x *TestFiltersRequest) Reset()
- func (x *TestFiltersRequest) String() string
- type TestFiltersResponse
- func (*TestFiltersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TestFiltersResponse) GetErrors() []string
- func (x *TestFiltersResponse) GetTestId() int64
- func (*TestFiltersResponse) ProtoMessage()
- func (x *TestFiltersResponse) ProtoReflect() protoreflect.Message
- func (x *TestFiltersResponse) Reset()
- func (x *TestFiltersResponse) String() string
- type UnimplementedObserverServiceServer
- type UnimplementedSnoozeThisLogServiceServer
- type UnsafeObserverServiceServer
- type UnsafeSnoozeThisLogServiceServer
- type UpdateFields
Constants ¶
This section is empty.
Variables ¶
var File_logwait_common_proto protoreflect.FileDescriptor
var File_observer_proto protoreflect.FileDescriptor
var File_scanner_proto protoreflect.FileDescriptor
var ObserverService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.snoozethis.logwait.ObserverService", HandlerType: (*ObserverServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Communicate", Handler: _ObserverService_Communicate_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "scanner.proto", }
ObserverService_ServiceDesc is the grpc.ServiceDesc for ObserverService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SnoozeThisLogService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.snoozethis.logwait.SnoozeThisLogService", HandlerType: (*SnoozeThisLogServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Communicate", Handler: _SnoozeThisLogService_Communicate_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "observer.proto", }
SnoozeThisLogService_ServiceDesc is the grpc.ServiceDesc for SnoozeThisLogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterObserverServiceServer ¶
func RegisterObserverServiceServer(s grpc.ServiceRegistrar, srv ObserverServiceServer)
func RegisterSnoozeThisLogServiceServer ¶
func RegisterSnoozeThisLogServiceServer(s grpc.ServiceRegistrar, srv SnoozeThisLogServiceServer)
Types ¶
type Filter ¶
type Filter struct { Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"` Regexp string `protobuf:"bytes,2,opt,name=regexp,proto3" json:"regexp,omitempty"` // contains filtered or unexported fields }
func (*Filter) Descriptor
deprecated
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) ProtoReflect ¶
func (x *Filter) ProtoReflect() protoreflect.Message
type Observable ¶
type Observable struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Signature string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` Filters []*Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"` // contains filtered or unexported fields }
func (*Observable) Descriptor
deprecated
func (*Observable) Descriptor() ([]byte, []int)
Deprecated: Use Observable.ProtoReflect.Descriptor instead.
func (*Observable) GetFilters ¶
func (x *Observable) GetFilters() []*Filter
func (*Observable) GetId ¶
func (x *Observable) GetId() string
func (*Observable) GetSignature ¶
func (x *Observable) GetSignature() string
func (*Observable) ProtoMessage ¶
func (*Observable) ProtoMessage()
func (*Observable) ProtoReflect ¶
func (x *Observable) ProtoReflect() protoreflect.Message
func (*Observable) Reset ¶
func (x *Observable) Reset()
func (*Observable) String ¶
func (x *Observable) String() string
type ObserverServiceClient ¶
type ObserverServiceClient interface {
Communicate(ctx context.Context, opts ...grpc.CallOption) (ObserverService_CommunicateClient, error)
}
ObserverServiceClient is the client API for ObserverService 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 NewObserverServiceClient ¶
func NewObserverServiceClient(cc grpc.ClientConnInterface) ObserverServiceClient
type ObserverServiceServer ¶
type ObserverServiceServer interface {
Communicate(ObserverService_CommunicateServer) error
}
ObserverServiceServer is the server API for ObserverService service. All implementations should embed UnimplementedObserverServiceServer for forward compatibility
type ObserverService_CommunicateClient ¶
type ObserverService_CommunicateClient interface { Send(*ScannerToObserver) error Recv() (*ObserverToScanner, error) grpc.ClientStream }
type ObserverService_CommunicateServer ¶
type ObserverService_CommunicateServer interface { Send(*ObserverToScanner) error Recv() (*ScannerToObserver, error) grpc.ServerStream }
type ObserverToScanner ¶
type ObserverToScanner struct { // Types that are assignable to Msg: // *ObserverToScanner_Register // *ObserverToScanner_NewObservable // *ObserverToScanner_CancelObservable // *ObserverToScanner_TestFilters Msg isObserverToScanner_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func (*ObserverToScanner) Descriptor
deprecated
func (*ObserverToScanner) Descriptor() ([]byte, []int)
Deprecated: Use ObserverToScanner.ProtoReflect.Descriptor instead.
func (*ObserverToScanner) GetCancelObservable ¶
func (x *ObserverToScanner) GetCancelObservable() string
func (*ObserverToScanner) GetMsg ¶
func (m *ObserverToScanner) GetMsg() isObserverToScanner_Msg
func (*ObserverToScanner) GetNewObservable ¶
func (x *ObserverToScanner) GetNewObservable() *Observable
func (*ObserverToScanner) GetRegister ¶
func (x *ObserverToScanner) GetRegister() *RegisterScannerResponse
func (*ObserverToScanner) GetTestFilters ¶
func (x *ObserverToScanner) GetTestFilters() *TestFiltersRequest
func (*ObserverToScanner) ProtoMessage ¶
func (*ObserverToScanner) ProtoMessage()
func (*ObserverToScanner) ProtoReflect ¶
func (x *ObserverToScanner) ProtoReflect() protoreflect.Message
func (*ObserverToScanner) Reset ¶
func (x *ObserverToScanner) Reset()
func (*ObserverToScanner) String ¶
func (x *ObserverToScanner) String() string
type ObserverToScanner_CancelObservable ¶
type ObserverToScanner_CancelObservable struct {
CancelObservable string `protobuf:"bytes,3,opt,name=cancel_observable,json=cancelObservable,proto3,oneof"`
}
type ObserverToScanner_NewObservable ¶
type ObserverToScanner_NewObservable struct {
NewObservable *Observable `protobuf:"bytes,2,opt,name=new_observable,json=newObservable,proto3,oneof"`
}
type ObserverToScanner_Register ¶
type ObserverToScanner_Register struct {
Register *RegisterScannerResponse `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}
type ObserverToScanner_TestFilters ¶
type ObserverToScanner_TestFilters struct {
TestFilters *TestFiltersRequest `protobuf:"bytes,4,opt,name=test_filters,json=testFilters,proto3,oneof"`
}
type ObserverToSnoozeThis ¶
type ObserverToSnoozeThis struct { // Types that are assignable to Msg: // *ObserverToSnoozeThis_Register // *ObserverToSnoozeThis_ObservedObservable // *ObserverToSnoozeThis_RejectObservable Msg isObserverToSnoozeThis_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func (*ObserverToSnoozeThis) Descriptor
deprecated
func (*ObserverToSnoozeThis) Descriptor() ([]byte, []int)
Deprecated: Use ObserverToSnoozeThis.ProtoReflect.Descriptor instead.
func (*ObserverToSnoozeThis) GetMsg ¶
func (m *ObserverToSnoozeThis) GetMsg() isObserverToSnoozeThis_Msg
func (*ObserverToSnoozeThis) GetObservedObservable ¶
func (x *ObserverToSnoozeThis) GetObservedObservable() string
func (*ObserverToSnoozeThis) GetRegister ¶
func (x *ObserverToSnoozeThis) GetRegister() *RegisterObserverRequest
func (*ObserverToSnoozeThis) GetRejectObservable ¶
func (x *ObserverToSnoozeThis) GetRejectObservable() *RejectObservable
func (*ObserverToSnoozeThis) ProtoMessage ¶
func (*ObserverToSnoozeThis) ProtoMessage()
func (*ObserverToSnoozeThis) ProtoReflect ¶
func (x *ObserverToSnoozeThis) ProtoReflect() protoreflect.Message
func (*ObserverToSnoozeThis) Reset ¶
func (x *ObserverToSnoozeThis) Reset()
func (*ObserverToSnoozeThis) String ¶
func (x *ObserverToSnoozeThis) String() string
type ObserverToSnoozeThis_ObservedObservable ¶
type ObserverToSnoozeThis_ObservedObservable struct {
ObservedObservable string `protobuf:"bytes,2,opt,name=observed_observable,json=observedObservable,proto3,oneof"`
}
type ObserverToSnoozeThis_Register ¶
type ObserverToSnoozeThis_Register struct {
Register *RegisterObserverRequest `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}
type ObserverToSnoozeThis_RejectObservable ¶
type ObserverToSnoozeThis_RejectObservable struct {
RejectObservable *RejectObservable `protobuf:"bytes,3,opt,name=reject_observable,json=rejectObservable,proto3,oneof"`
}
type RegisterObserverRequest ¶
type RegisterObserverRequest struct { LogInstanceToken string `protobuf:"bytes,1,opt,name=log_instance_token,json=logInstanceToken,proto3" json:"log_instance_token,omitempty"` // Send a version number so we can see how far we need to maintain backwards compatibility. ObserverProtocolVersion int32 `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RegisterObserverRequest) Descriptor
deprecated
func (*RegisterObserverRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterObserverRequest.ProtoReflect.Descriptor instead.
func (*RegisterObserverRequest) GetLogInstanceToken ¶
func (x *RegisterObserverRequest) GetLogInstanceToken() string
func (*RegisterObserverRequest) GetObserverProtocolVersion ¶
func (x *RegisterObserverRequest) GetObserverProtocolVersion() int32
func (*RegisterObserverRequest) ProtoMessage ¶
func (*RegisterObserverRequest) ProtoMessage()
func (*RegisterObserverRequest) ProtoReflect ¶
func (x *RegisterObserverRequest) ProtoReflect() protoreflect.Message
func (*RegisterObserverRequest) Reset ¶
func (x *RegisterObserverRequest) Reset()
func (*RegisterObserverRequest) String ¶
func (x *RegisterObserverRequest) String() string
type RegisterObserverResponse ¶
type RegisterObserverResponse struct { ActiveObservables []*Observable `protobuf:"bytes,1,rep,name=active_observables,json=activeObservables,proto3" json:"active_observables,omitempty"` // The url you've registered with SnoozeThis. The Observer should use this URL as the base for filter-URLs to ensure the domain is understood by SnoozeThis. RegisteredUrl string `protobuf:"bytes,2,opt,name=registered_url,json=registeredUrl,proto3" json:"registered_url,omitempty"` // contains filtered or unexported fields }
func (*RegisterObserverResponse) Descriptor
deprecated
func (*RegisterObserverResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterObserverResponse.ProtoReflect.Descriptor instead.
func (*RegisterObserverResponse) GetActiveObservables ¶
func (x *RegisterObserverResponse) GetActiveObservables() []*Observable
func (*RegisterObserverResponse) GetRegisteredUrl ¶
func (x *RegisterObserverResponse) GetRegisteredUrl() string
func (*RegisterObserverResponse) ProtoMessage ¶
func (*RegisterObserverResponse) ProtoMessage()
func (*RegisterObserverResponse) ProtoReflect ¶
func (x *RegisterObserverResponse) ProtoReflect() protoreflect.Message
func (*RegisterObserverResponse) Reset ¶
func (x *RegisterObserverResponse) Reset()
func (*RegisterObserverResponse) String ¶
func (x *RegisterObserverResponse) String() string
type RegisterScannerRequest ¶
type RegisterScannerRequest struct { // All scanners to one observer should be the same binary, for example so that they all understand the same filters. This is enforced by them needing to send their type (e.g. "syslog") to the observer which checks they're all the same. ScannerType string `protobuf:"bytes,1,opt,name=scanner_type,json=scannerType,proto3" json:"scanner_type,omitempty"` // contains filtered or unexported fields }
func (*RegisterScannerRequest) Descriptor
deprecated
func (*RegisterScannerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterScannerRequest.ProtoReflect.Descriptor instead.
func (*RegisterScannerRequest) GetScannerType ¶
func (x *RegisterScannerRequest) GetScannerType() string
func (*RegisterScannerRequest) ProtoMessage ¶
func (*RegisterScannerRequest) ProtoMessage()
func (*RegisterScannerRequest) ProtoReflect ¶
func (x *RegisterScannerRequest) ProtoReflect() protoreflect.Message
func (*RegisterScannerRequest) Reset ¶
func (x *RegisterScannerRequest) Reset()
func (*RegisterScannerRequest) String ¶
func (x *RegisterScannerRequest) String() string
type RegisterScannerResponse ¶
type RegisterScannerResponse struct { ActiveObservables []*Observable `protobuf:"bytes,1,rep,name=active_observables,json=activeObservables,proto3" json:"active_observables,omitempty"` // contains filtered or unexported fields }
func (*RegisterScannerResponse) Descriptor
deprecated
func (*RegisterScannerResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterScannerResponse.ProtoReflect.Descriptor instead.
func (*RegisterScannerResponse) GetActiveObservables ¶
func (x *RegisterScannerResponse) GetActiveObservables() []*Observable
func (*RegisterScannerResponse) ProtoMessage ¶
func (*RegisterScannerResponse) ProtoMessage()
func (*RegisterScannerResponse) ProtoReflect ¶
func (x *RegisterScannerResponse) ProtoReflect() protoreflect.Message
func (*RegisterScannerResponse) Reset ¶
func (x *RegisterScannerResponse) Reset()
func (*RegisterScannerResponse) String ¶
func (x *RegisterScannerResponse) String() string
type RejectObservable ¶
type RejectObservable struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*RejectObservable) Descriptor
deprecated
func (*RejectObservable) Descriptor() ([]byte, []int)
Deprecated: Use RejectObservable.ProtoReflect.Descriptor instead.
func (*RejectObservable) GetId ¶
func (x *RejectObservable) GetId() string
func (*RejectObservable) GetMessage ¶
func (x *RejectObservable) GetMessage() string
func (*RejectObservable) ProtoMessage ¶
func (*RejectObservable) ProtoMessage()
func (*RejectObservable) ProtoReflect ¶
func (x *RejectObservable) ProtoReflect() protoreflect.Message
func (*RejectObservable) Reset ¶
func (x *RejectObservable) Reset()
func (*RejectObservable) String ¶
func (x *RejectObservable) String() string
type ScannerToObserver ¶
type ScannerToObserver struct { // Types that are assignable to Msg: // *ScannerToObserver_Register // *ScannerToObserver_ObservedObservable // *ScannerToObserver_RejectObservable // *ScannerToObserver_TestFilters // *ScannerToObserver_UpdateFields Msg isScannerToObserver_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func (*ScannerToObserver) Descriptor
deprecated
func (*ScannerToObserver) Descriptor() ([]byte, []int)
Deprecated: Use ScannerToObserver.ProtoReflect.Descriptor instead.
func (*ScannerToObserver) GetMsg ¶
func (m *ScannerToObserver) GetMsg() isScannerToObserver_Msg
func (*ScannerToObserver) GetObservedObservable ¶
func (x *ScannerToObserver) GetObservedObservable() string
func (*ScannerToObserver) GetRegister ¶
func (x *ScannerToObserver) GetRegister() *RegisterScannerRequest
func (*ScannerToObserver) GetRejectObservable ¶
func (x *ScannerToObserver) GetRejectObservable() *RejectObservable
func (*ScannerToObserver) GetTestFilters ¶
func (x *ScannerToObserver) GetTestFilters() *TestFiltersResponse
func (*ScannerToObserver) GetUpdateFields ¶
func (x *ScannerToObserver) GetUpdateFields() *UpdateFields
func (*ScannerToObserver) ProtoMessage ¶
func (*ScannerToObserver) ProtoMessage()
func (*ScannerToObserver) ProtoReflect ¶
func (x *ScannerToObserver) ProtoReflect() protoreflect.Message
func (*ScannerToObserver) Reset ¶
func (x *ScannerToObserver) Reset()
func (*ScannerToObserver) String ¶
func (x *ScannerToObserver) String() string
type ScannerToObserver_ObservedObservable ¶
type ScannerToObserver_ObservedObservable struct {
ObservedObservable string `protobuf:"bytes,2,opt,name=observed_observable,json=observedObservable,proto3,oneof"`
}
type ScannerToObserver_Register ¶
type ScannerToObserver_Register struct {
Register *RegisterScannerRequest `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}
type ScannerToObserver_RejectObservable ¶
type ScannerToObserver_RejectObservable struct {
RejectObservable *RejectObservable `protobuf:"bytes,3,opt,name=reject_observable,json=rejectObservable,proto3,oneof"`
}
type ScannerToObserver_TestFilters ¶
type ScannerToObserver_TestFilters struct {
TestFilters *TestFiltersResponse `protobuf:"bytes,4,opt,name=test_filters,json=testFilters,proto3,oneof"`
}
type ScannerToObserver_UpdateFields ¶
type ScannerToObserver_UpdateFields struct {
UpdateFields *UpdateFields `protobuf:"bytes,5,opt,name=update_fields,json=updateFields,proto3,oneof"`
}
type SnoozeThisLogServiceClient ¶
type SnoozeThisLogServiceClient interface {
Communicate(ctx context.Context, opts ...grpc.CallOption) (SnoozeThisLogService_CommunicateClient, error)
}
SnoozeThisLogServiceClient is the client API for SnoozeThisLogService 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 NewSnoozeThisLogServiceClient ¶
func NewSnoozeThisLogServiceClient(cc grpc.ClientConnInterface) SnoozeThisLogServiceClient
type SnoozeThisLogServiceServer ¶
type SnoozeThisLogServiceServer interface {
Communicate(SnoozeThisLogService_CommunicateServer) error
}
SnoozeThisLogServiceServer is the server API for SnoozeThisLogService service. All implementations should embed UnimplementedSnoozeThisLogServiceServer for forward compatibility
type SnoozeThisLogService_CommunicateClient ¶
type SnoozeThisLogService_CommunicateClient interface { Send(*ObserverToSnoozeThis) error Recv() (*SnoozeThisToObserver, error) grpc.ClientStream }
type SnoozeThisLogService_CommunicateServer ¶
type SnoozeThisLogService_CommunicateServer interface { Send(*SnoozeThisToObserver) error Recv() (*ObserverToSnoozeThis, error) grpc.ServerStream }
type SnoozeThisToObserver ¶
type SnoozeThisToObserver struct { // Types that are assignable to Msg: // *SnoozeThisToObserver_Register // *SnoozeThisToObserver_NewObservable // *SnoozeThisToObserver_CancelObservable Msg isSnoozeThisToObserver_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func (*SnoozeThisToObserver) Descriptor
deprecated
func (*SnoozeThisToObserver) Descriptor() ([]byte, []int)
Deprecated: Use SnoozeThisToObserver.ProtoReflect.Descriptor instead.
func (*SnoozeThisToObserver) GetCancelObservable ¶
func (x *SnoozeThisToObserver) GetCancelObservable() string
func (*SnoozeThisToObserver) GetMsg ¶
func (m *SnoozeThisToObserver) GetMsg() isSnoozeThisToObserver_Msg
func (*SnoozeThisToObserver) GetNewObservable ¶
func (x *SnoozeThisToObserver) GetNewObservable() *Observable
func (*SnoozeThisToObserver) GetRegister ¶
func (x *SnoozeThisToObserver) GetRegister() *RegisterObserverResponse
func (*SnoozeThisToObserver) ProtoMessage ¶
func (*SnoozeThisToObserver) ProtoMessage()
func (*SnoozeThisToObserver) ProtoReflect ¶
func (x *SnoozeThisToObserver) ProtoReflect() protoreflect.Message
func (*SnoozeThisToObserver) Reset ¶
func (x *SnoozeThisToObserver) Reset()
func (*SnoozeThisToObserver) String ¶
func (x *SnoozeThisToObserver) String() string
type SnoozeThisToObserver_CancelObservable ¶
type SnoozeThisToObserver_CancelObservable struct {
CancelObservable string `protobuf:"bytes,3,opt,name=cancel_observable,json=cancelObservable,proto3,oneof"`
}
type SnoozeThisToObserver_NewObservable ¶
type SnoozeThisToObserver_NewObservable struct {
NewObservable *Observable `protobuf:"bytes,2,opt,name=new_observable,json=newObservable,proto3,oneof"`
}
type SnoozeThisToObserver_Register ¶
type SnoozeThisToObserver_Register struct {
Register *RegisterObserverResponse `protobuf:"bytes,1,opt,name=register,proto3,oneof"`
}
type TestFiltersRequest ¶
type TestFiltersRequest struct { TestId int64 `protobuf:"varint,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"` Filters []*Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"` // contains filtered or unexported fields }
func (*TestFiltersRequest) Descriptor
deprecated
func (*TestFiltersRequest) Descriptor() ([]byte, []int)
Deprecated: Use TestFiltersRequest.ProtoReflect.Descriptor instead.
func (*TestFiltersRequest) GetFilters ¶
func (x *TestFiltersRequest) GetFilters() []*Filter
func (*TestFiltersRequest) GetTestId ¶
func (x *TestFiltersRequest) GetTestId() int64
func (*TestFiltersRequest) ProtoMessage ¶
func (*TestFiltersRequest) ProtoMessage()
func (*TestFiltersRequest) ProtoReflect ¶
func (x *TestFiltersRequest) ProtoReflect() protoreflect.Message
func (*TestFiltersRequest) Reset ¶
func (x *TestFiltersRequest) Reset()
func (*TestFiltersRequest) String ¶
func (x *TestFiltersRequest) String() string
type TestFiltersResponse ¶
type TestFiltersResponse struct { TestId int64 `protobuf:"varint,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"` Errors []string `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"` // contains filtered or unexported fields }
func (*TestFiltersResponse) Descriptor
deprecated
func (*TestFiltersResponse) Descriptor() ([]byte, []int)
Deprecated: Use TestFiltersResponse.ProtoReflect.Descriptor instead.
func (*TestFiltersResponse) GetErrors ¶
func (x *TestFiltersResponse) GetErrors() []string
func (*TestFiltersResponse) GetTestId ¶
func (x *TestFiltersResponse) GetTestId() int64
func (*TestFiltersResponse) ProtoMessage ¶
func (*TestFiltersResponse) ProtoMessage()
func (*TestFiltersResponse) ProtoReflect ¶
func (x *TestFiltersResponse) ProtoReflect() protoreflect.Message
func (*TestFiltersResponse) Reset ¶
func (x *TestFiltersResponse) Reset()
func (*TestFiltersResponse) String ¶
func (x *TestFiltersResponse) String() string
type UnimplementedObserverServiceServer ¶
type UnimplementedObserverServiceServer struct { }
UnimplementedObserverServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedObserverServiceServer) Communicate ¶
func (UnimplementedObserverServiceServer) Communicate(ObserverService_CommunicateServer) error
type UnimplementedSnoozeThisLogServiceServer ¶
type UnimplementedSnoozeThisLogServiceServer struct { }
UnimplementedSnoozeThisLogServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedSnoozeThisLogServiceServer) Communicate ¶
func (UnimplementedSnoozeThisLogServiceServer) Communicate(SnoozeThisLogService_CommunicateServer) error
type UnsafeObserverServiceServer ¶
type UnsafeObserverServiceServer interface {
// contains filtered or unexported methods
}
UnsafeObserverServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ObserverServiceServer will result in compilation errors.
type UnsafeSnoozeThisLogServiceServer ¶
type UnsafeSnoozeThisLogServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSnoozeThisLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SnoozeThisLogServiceServer will result in compilation errors.
type UpdateFields ¶
type UpdateFields struct { // List of fields users can filter on. Fields []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
func (*UpdateFields) Descriptor
deprecated
func (*UpdateFields) Descriptor() ([]byte, []int)
Deprecated: Use UpdateFields.ProtoReflect.Descriptor instead.
func (*UpdateFields) GetFields ¶
func (x *UpdateFields) GetFields() []string
func (*UpdateFields) ProtoMessage ¶
func (*UpdateFields) ProtoMessage()
func (*UpdateFields) ProtoReflect ¶
func (x *UpdateFields) ProtoReflect() protoreflect.Message
func (*UpdateFields) Reset ¶
func (x *UpdateFields) Reset()
func (*UpdateFields) String ¶
func (x *UpdateFields) String() string