Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + var ErrIntOverflowSensor = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthSensor = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupSensor = fmt.Errorf("proto: unexpected end of group") + func RegisterSensorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterSensorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SensorServiceClient) error + func RegisterSensorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterSensorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SensorServiceServer) error + func RegisterSensorServiceServer(s *grpc.Server, srv SensorServiceServer) + type CreateSensorRequest struct + CreateOptions *v1.CreateOptions + Namespace string + Sensor *v1alpha1.Sensor + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateSensorRequest) Descriptor() ([]byte, []int) + func (*CreateSensorRequest) ProtoMessage() + func (m *CreateSensorRequest) GetCreateOptions() *v1.CreateOptions + func (m *CreateSensorRequest) GetNamespace() string + func (m *CreateSensorRequest) GetSensor() *v1alpha1.Sensor + func (m *CreateSensorRequest) Marshal() (dAtA []byte, err error) + func (m *CreateSensorRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateSensorRequest) Reset() + func (m *CreateSensorRequest) Size() (n int) + func (m *CreateSensorRequest) String() string + func (m *CreateSensorRequest) Unmarshal(dAtA []byte) error + func (m *CreateSensorRequest) XXX_DiscardUnknown() + func (m *CreateSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateSensorRequest) XXX_Merge(src proto.Message) + func (m *CreateSensorRequest) XXX_Size() int + func (m *CreateSensorRequest) XXX_Unmarshal(b []byte) error + type DeleteSensorRequest struct + DeleteOptions *v1.DeleteOptions + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteSensorRequest) Descriptor() ([]byte, []int) + func (*DeleteSensorRequest) ProtoMessage() + func (m *DeleteSensorRequest) GetDeleteOptions() *v1.DeleteOptions + func (m *DeleteSensorRequest) GetName() string + func (m *DeleteSensorRequest) GetNamespace() string + func (m *DeleteSensorRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteSensorRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteSensorRequest) Reset() + func (m *DeleteSensorRequest) Size() (n int) + func (m *DeleteSensorRequest) String() string + func (m *DeleteSensorRequest) Unmarshal(dAtA []byte) error + func (m *DeleteSensorRequest) XXX_DiscardUnknown() + func (m *DeleteSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteSensorRequest) XXX_Merge(src proto.Message) + func (m *DeleteSensorRequest) XXX_Size() int + func (m *DeleteSensorRequest) XXX_Unmarshal(b []byte) error + type DeleteSensorResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteSensorResponse) Descriptor() ([]byte, []int) + func (*DeleteSensorResponse) ProtoMessage() + func (m *DeleteSensorResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteSensorResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteSensorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteSensorResponse) Reset() + func (m *DeleteSensorResponse) Size() (n int) + func (m *DeleteSensorResponse) String() string + func (m *DeleteSensorResponse) Unmarshal(dAtA []byte) error + func (m *DeleteSensorResponse) XXX_DiscardUnknown() + func (m *DeleteSensorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteSensorResponse) XXX_Merge(src proto.Message) + func (m *DeleteSensorResponse) XXX_Size() int + func (m *DeleteSensorResponse) XXX_Unmarshal(b []byte) error + type GetSensorRequest struct + GetOptions *v1.GetOptions + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetSensorRequest) Descriptor() ([]byte, []int) + func (*GetSensorRequest) ProtoMessage() + func (m *GetSensorRequest) GetGetOptions() *v1.GetOptions + func (m *GetSensorRequest) GetName() string + func (m *GetSensorRequest) GetNamespace() string + func (m *GetSensorRequest) Marshal() (dAtA []byte, err error) + func (m *GetSensorRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetSensorRequest) Reset() + func (m *GetSensorRequest) Size() (n int) + func (m *GetSensorRequest) String() string + func (m *GetSensorRequest) Unmarshal(dAtA []byte) error + func (m *GetSensorRequest) XXX_DiscardUnknown() + func (m *GetSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetSensorRequest) XXX_Merge(src proto.Message) + func (m *GetSensorRequest) XXX_Size() int + func (m *GetSensorRequest) XXX_Unmarshal(b []byte) error + type ListSensorsRequest struct + ListOptions *v1.ListOptions + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListSensorsRequest) Descriptor() ([]byte, []int) + func (*ListSensorsRequest) ProtoMessage() + func (m *ListSensorsRequest) GetListOptions() *v1.ListOptions + func (m *ListSensorsRequest) GetNamespace() string + func (m *ListSensorsRequest) Marshal() (dAtA []byte, err error) + func (m *ListSensorsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListSensorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListSensorsRequest) Reset() + func (m *ListSensorsRequest) Size() (n int) + func (m *ListSensorsRequest) String() string + func (m *ListSensorsRequest) Unmarshal(dAtA []byte) error + func (m *ListSensorsRequest) XXX_DiscardUnknown() + func (m *ListSensorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListSensorsRequest) XXX_Merge(src proto.Message) + func (m *ListSensorsRequest) XXX_Size() int + func (m *ListSensorsRequest) XXX_Unmarshal(b []byte) error + type LogEntry struct + DependencyName string + EventContext string + Level string + Msg string + Namespace string + SensorName string + Time *v1.Time + TriggerName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogEntry) Descriptor() ([]byte, []int) + func (*LogEntry) ProtoMessage() + func (m *LogEntry) GetDependencyName() string + func (m *LogEntry) GetEventContext() string + func (m *LogEntry) GetLevel() string + func (m *LogEntry) GetMsg() string + func (m *LogEntry) GetNamespace() string + func (m *LogEntry) GetSensorName() string + func (m *LogEntry) GetTime() *v1.Time + func (m *LogEntry) GetTriggerName() string + func (m *LogEntry) Marshal() (dAtA []byte, err error) + func (m *LogEntry) MarshalTo(dAtA []byte) (int, error) + func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LogEntry) Reset() + func (m *LogEntry) Size() (n int) + func (m *LogEntry) String() string + func (m *LogEntry) Unmarshal(dAtA []byte) error + func (m *LogEntry) XXX_DiscardUnknown() + func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogEntry) XXX_Merge(src proto.Message) + func (m *LogEntry) XXX_Size() int + func (m *LogEntry) XXX_Unmarshal(b []byte) error + type SensorServiceClient interface + CreateSensor func(ctx context.Context, in *CreateSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error) + DeleteSensor func(ctx context.Context, in *DeleteSensorRequest, opts ...grpc.CallOption) (*DeleteSensorResponse, error) + GetSensor func(ctx context.Context, in *GetSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error) + ListSensors func(ctx context.Context, in *ListSensorsRequest, opts ...grpc.CallOption) (*v1alpha1.SensorList, error) + SensorsLogs func(ctx context.Context, in *SensorsLogsRequest, opts ...grpc.CallOption) (SensorService_SensorsLogsClient, error) + UpdateSensor func(ctx context.Context, in *UpdateSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error) + WatchSensors func(ctx context.Context, in *ListSensorsRequest, opts ...grpc.CallOption) (SensorService_WatchSensorsClient, error) + func NewSensorServiceClient(cc *grpc.ClientConn) SensorServiceClient + type SensorServiceServer interface + CreateSensor func(context.Context, *CreateSensorRequest) (*v1alpha1.Sensor, error) + DeleteSensor func(context.Context, *DeleteSensorRequest) (*DeleteSensorResponse, error) + GetSensor func(context.Context, *GetSensorRequest) (*v1alpha1.Sensor, error) + ListSensors func(context.Context, *ListSensorsRequest) (*v1alpha1.SensorList, error) + SensorsLogs func(*SensorsLogsRequest, SensorService_SensorsLogsServer) error + UpdateSensor func(context.Context, *UpdateSensorRequest) (*v1alpha1.Sensor, error) + WatchSensors func(*ListSensorsRequest, SensorService_WatchSensorsServer) error + type SensorService_SensorsLogsClient interface + Recv func() (*LogEntry, error) + type SensorService_SensorsLogsServer interface + Send func(*LogEntry) error + type SensorService_WatchSensorsClient interface + Recv func() (*SensorWatchEvent, error) + type SensorService_WatchSensorsServer interface + Send func(*SensorWatchEvent) error + type SensorWatchEvent struct + Object *v1alpha1.Sensor + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SensorWatchEvent) Descriptor() ([]byte, []int) + func (*SensorWatchEvent) ProtoMessage() + func (m *SensorWatchEvent) GetObject() *v1alpha1.Sensor + func (m *SensorWatchEvent) GetType() string + func (m *SensorWatchEvent) Marshal() (dAtA []byte, err error) + func (m *SensorWatchEvent) MarshalTo(dAtA []byte) (int, error) + func (m *SensorWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SensorWatchEvent) Reset() + func (m *SensorWatchEvent) Size() (n int) + func (m *SensorWatchEvent) String() string + func (m *SensorWatchEvent) Unmarshal(dAtA []byte) error + func (m *SensorWatchEvent) XXX_DiscardUnknown() + func (m *SensorWatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SensorWatchEvent) XXX_Merge(src proto.Message) + func (m *SensorWatchEvent) XXX_Size() int + func (m *SensorWatchEvent) XXX_Unmarshal(b []byte) error + type SensorsLogsRequest struct + Grep string + Name string + Namespace string + PodLogOptions *v11.PodLogOptions + TriggerName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SensorsLogsRequest) Descriptor() ([]byte, []int) + func (*SensorsLogsRequest) ProtoMessage() + func (m *SensorsLogsRequest) GetGrep() string + func (m *SensorsLogsRequest) GetName() string + func (m *SensorsLogsRequest) GetNamespace() string + func (m *SensorsLogsRequest) GetPodLogOptions() *v11.PodLogOptions + func (m *SensorsLogsRequest) GetTriggerName() string + func (m *SensorsLogsRequest) Marshal() (dAtA []byte, err error) + func (m *SensorsLogsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SensorsLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SensorsLogsRequest) Reset() + func (m *SensorsLogsRequest) Size() (n int) + func (m *SensorsLogsRequest) String() string + func (m *SensorsLogsRequest) Unmarshal(dAtA []byte) error + func (m *SensorsLogsRequest) XXX_DiscardUnknown() + func (m *SensorsLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SensorsLogsRequest) XXX_Merge(src proto.Message) + func (m *SensorsLogsRequest) XXX_Size() int + func (m *SensorsLogsRequest) XXX_Unmarshal(b []byte) error + type UnimplementedSensorServiceServer struct + func (*UnimplementedSensorServiceServer) CreateSensor(ctx context.Context, req *CreateSensorRequest) (*v1alpha1.Sensor, error) + func (*UnimplementedSensorServiceServer) DeleteSensor(ctx context.Context, req *DeleteSensorRequest) (*DeleteSensorResponse, error) + func (*UnimplementedSensorServiceServer) GetSensor(ctx context.Context, req *GetSensorRequest) (*v1alpha1.Sensor, error) + func (*UnimplementedSensorServiceServer) ListSensors(ctx context.Context, req *ListSensorsRequest) (*v1alpha1.SensorList, error) + func (*UnimplementedSensorServiceServer) SensorsLogs(req *SensorsLogsRequest, srv SensorService_SensorsLogsServer) error + func (*UnimplementedSensorServiceServer) UpdateSensor(ctx context.Context, req *UpdateSensorRequest) (*v1alpha1.Sensor, error) + func (*UnimplementedSensorServiceServer) WatchSensors(req *ListSensorsRequest, srv SensorService_WatchSensorsServer) error + type UpdateSensorRequest struct + Name string + Namespace string + Sensor *v1alpha1.Sensor + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateSensorRequest) Descriptor() ([]byte, []int) + func (*UpdateSensorRequest) ProtoMessage() + func (m *UpdateSensorRequest) GetName() string + func (m *UpdateSensorRequest) GetNamespace() string + func (m *UpdateSensorRequest) GetSensor() *v1alpha1.Sensor + func (m *UpdateSensorRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateSensorRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateSensorRequest) Reset() + func (m *UpdateSensorRequest) Size() (n int) + func (m *UpdateSensorRequest) String() string + func (m *UpdateSensorRequest) Unmarshal(dAtA []byte) error + func (m *UpdateSensorRequest) XXX_DiscardUnknown() + func (m *UpdateSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateSensorRequest) XXX_Merge(src proto.Message) + func (m *UpdateSensorRequest) XXX_Size() int + func (m *UpdateSensorRequest) XXX_Unmarshal(b []byte) error