sensor

package
v3.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 31, 2024 License: Apache-2.0 Imports: 21 Imported by: 4

Documentation

Overview

Package sensor is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSensor        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSensor          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSensor = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterSensorServiceHandler 

func RegisterSensorServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSensorServiceHandler registers the http handlers for service SensorService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSensorServiceHandlerClient 

func RegisterSensorServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SensorServiceClient) error

RegisterSensorServiceHandlerClient registers the http handlers for service SensorService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SensorServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SensorServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SensorServiceClient" to call the correct interceptors.

func RegisterSensorServiceHandlerFromEndpoint 

func RegisterSensorServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSensorServiceHandlerFromEndpoint is same as RegisterSensorServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSensorServiceHandlerServer 

func RegisterSensorServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SensorServiceServer) error

RegisterSensorServiceHandlerServer registers the http handlers for service SensorService to "mux". UnaryRPC :call SensorServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterSensorServiceHandlerFromEndpoint instead.

func RegisterSensorServiceServer 

func RegisterSensorServiceServer(s *grpc.Server, srv SensorServiceServer)

Types

type CreateSensorRequest 

type CreateSensorRequest struct {
	Namespace            string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Sensor               *v1alpha1.Sensor  `protobuf:"bytes,2,opt,name=sensor,proto3" json:"sensor,omitempty"`
	CreateOptions        *v1.CreateOptions `protobuf:"bytes,3,opt,name=createOptions,proto3" json:"createOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateSensorRequest) Descriptor 

func (*CreateSensorRequest) Descriptor() ([]byte, []int)

func (*CreateSensorRequest) GetCreateOptions 

func (m *CreateSensorRequest) GetCreateOptions() *v1.CreateOptions

func (*CreateSensorRequest) GetNamespace 

func (m *CreateSensorRequest) GetNamespace() string

func (*CreateSensorRequest) GetSensor 

func (m *CreateSensorRequest) GetSensor() *v1alpha1.Sensor

func (*CreateSensorRequest) Marshal 

func (m *CreateSensorRequest) Marshal() (dAtA []byte, err error)

func (*CreateSensorRequest) MarshalTo 

func (m *CreateSensorRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateSensorRequest) MarshalToSizedBuffer 

func (m *CreateSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateSensorRequest) ProtoMessage 

func (*CreateSensorRequest) ProtoMessage()

func (*CreateSensorRequest) Reset 

func (m *CreateSensorRequest) Reset()

func (*CreateSensorRequest) Size 

func (m *CreateSensorRequest) Size() (n int)

func (*CreateSensorRequest) String 

func (m *CreateSensorRequest) String() string

func (*CreateSensorRequest) Unmarshal 

func (m *CreateSensorRequest) Unmarshal(dAtA []byte) error

func (*CreateSensorRequest) XXX_DiscardUnknown 

func (m *CreateSensorRequest) XXX_DiscardUnknown()

func (*CreateSensorRequest) XXX_Marshal 

func (m *CreateSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSensorRequest) XXX_Merge 

func (m *CreateSensorRequest) XXX_Merge(src proto.Message)

func (*CreateSensorRequest) XXX_Size 

func (m *CreateSensorRequest) XXX_Size() int

func (*CreateSensorRequest) XXX_Unmarshal 

func (m *CreateSensorRequest) XXX_Unmarshal(b []byte) error

type DeleteSensorRequest 

type DeleteSensorRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DeleteOptions        *v1.DeleteOptions `protobuf:"bytes,3,opt,name=deleteOptions,proto3" json:"deleteOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DeleteSensorRequest) Descriptor 

func (*DeleteSensorRequest) Descriptor() ([]byte, []int)

func (*DeleteSensorRequest) GetDeleteOptions 

func (m *DeleteSensorRequest) GetDeleteOptions() *v1.DeleteOptions

func (*DeleteSensorRequest) GetName 

func (m *DeleteSensorRequest) GetName() string

func (*DeleteSensorRequest) GetNamespace 

func (m *DeleteSensorRequest) GetNamespace() string

func (*DeleteSensorRequest) Marshal 

func (m *DeleteSensorRequest) Marshal() (dAtA []byte, err error)

func (*DeleteSensorRequest) MarshalTo 

func (m *DeleteSensorRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSensorRequest) MarshalToSizedBuffer 

func (m *DeleteSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteSensorRequest) ProtoMessage 

func (*DeleteSensorRequest) ProtoMessage()

func (*DeleteSensorRequest) Reset 

func (m *DeleteSensorRequest) Reset()

func (*DeleteSensorRequest) Size 

func (m *DeleteSensorRequest) Size() (n int)

func (*DeleteSensorRequest) String 

func (m *DeleteSensorRequest) String() string

func (*DeleteSensorRequest) Unmarshal 

func (m *DeleteSensorRequest) Unmarshal(dAtA []byte) error

func (*DeleteSensorRequest) XXX_DiscardUnknown 

func (m *DeleteSensorRequest) XXX_DiscardUnknown()

func (*DeleteSensorRequest) XXX_Marshal 

func (m *DeleteSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSensorRequest) XXX_Merge 

func (m *DeleteSensorRequest) XXX_Merge(src proto.Message)

func (*DeleteSensorRequest) XXX_Size 

func (m *DeleteSensorRequest) XXX_Size() int

func (*DeleteSensorRequest) XXX_Unmarshal 

func (m *DeleteSensorRequest) XXX_Unmarshal(b []byte) error

type DeleteSensorResponse 

type DeleteSensorResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteSensorResponse) Descriptor 

func (*DeleteSensorResponse) Descriptor() ([]byte, []int)

func (*DeleteSensorResponse) Marshal 

func (m *DeleteSensorResponse) Marshal() (dAtA []byte, err error)

func (*DeleteSensorResponse) MarshalTo 

func (m *DeleteSensorResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteSensorResponse) MarshalToSizedBuffer 

func (m *DeleteSensorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteSensorResponse) ProtoMessage 

func (*DeleteSensorResponse) ProtoMessage()

func (*DeleteSensorResponse) Reset 

func (m *DeleteSensorResponse) Reset()

func (*DeleteSensorResponse) Size 

func (m *DeleteSensorResponse) Size() (n int)

func (*DeleteSensorResponse) String 

func (m *DeleteSensorResponse) String() string

func (*DeleteSensorResponse) Unmarshal 

func (m *DeleteSensorResponse) Unmarshal(dAtA []byte) error

func (*DeleteSensorResponse) XXX_DiscardUnknown 

func (m *DeleteSensorResponse) XXX_DiscardUnknown()

func (*DeleteSensorResponse) XXX_Marshal 

func (m *DeleteSensorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteSensorResponse) XXX_Merge 

func (m *DeleteSensorResponse) XXX_Merge(src proto.Message)

func (*DeleteSensorResponse) XXX_Size 

func (m *DeleteSensorResponse) XXX_Size() int

func (*DeleteSensorResponse) XXX_Unmarshal 

func (m *DeleteSensorResponse) XXX_Unmarshal(b []byte) error

type GetSensorRequest 

type GetSensorRequest struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions           *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetSensorRequest) Descriptor 

func (*GetSensorRequest) Descriptor() ([]byte, []int)

func (*GetSensorRequest) GetGetOptions 

func (m *GetSensorRequest) GetGetOptions() *v1.GetOptions

func (*GetSensorRequest) GetName 

func (m *GetSensorRequest) GetName() string

func (*GetSensorRequest) GetNamespace 

func (m *GetSensorRequest) GetNamespace() string

func (*GetSensorRequest) Marshal 

func (m *GetSensorRequest) Marshal() (dAtA []byte, err error)

func (*GetSensorRequest) MarshalTo 

func (m *GetSensorRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetSensorRequest) MarshalToSizedBuffer 

func (m *GetSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetSensorRequest) ProtoMessage 

func (*GetSensorRequest) ProtoMessage()

func (*GetSensorRequest) Reset 

func (m *GetSensorRequest) Reset()

func (*GetSensorRequest) Size 

func (m *GetSensorRequest) Size() (n int)

func (*GetSensorRequest) String 

func (m *GetSensorRequest) String() string

func (*GetSensorRequest) Unmarshal 

func (m *GetSensorRequest) Unmarshal(dAtA []byte) error

func (*GetSensorRequest) XXX_DiscardUnknown 

func (m *GetSensorRequest) XXX_DiscardUnknown()

func (*GetSensorRequest) XXX_Marshal 

func (m *GetSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetSensorRequest) XXX_Merge 

func (m *GetSensorRequest) XXX_Merge(src proto.Message)

func (*GetSensorRequest) XXX_Size 

func (m *GetSensorRequest) XXX_Size() int

func (*GetSensorRequest) XXX_Unmarshal 

func (m *GetSensorRequest) XXX_Unmarshal(b []byte) error

type ListSensorsRequest 

type ListSensorsRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListSensorsRequest) Descriptor 

func (*ListSensorsRequest) Descriptor() ([]byte, []int)

func (*ListSensorsRequest) GetListOptions 

func (m *ListSensorsRequest) GetListOptions() *v1.ListOptions

func (*ListSensorsRequest) GetNamespace 

func (m *ListSensorsRequest) GetNamespace() string

func (*ListSensorsRequest) Marshal 

func (m *ListSensorsRequest) Marshal() (dAtA []byte, err error)

func (*ListSensorsRequest) MarshalTo 

func (m *ListSensorsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListSensorsRequest) MarshalToSizedBuffer 

func (m *ListSensorsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSensorsRequest) ProtoMessage 

func (*ListSensorsRequest) ProtoMessage()

func (*ListSensorsRequest) Reset 

func (m *ListSensorsRequest) Reset()

func (*ListSensorsRequest) Size 

func (m *ListSensorsRequest) Size() (n int)

func (*ListSensorsRequest) String 

func (m *ListSensorsRequest) String() string

func (*ListSensorsRequest) Unmarshal 

func (m *ListSensorsRequest) Unmarshal(dAtA []byte) error

func (*ListSensorsRequest) XXX_DiscardUnknown 

func (m *ListSensorsRequest) XXX_DiscardUnknown()

func (*ListSensorsRequest) XXX_Marshal 

func (m *ListSensorsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSensorsRequest) XXX_Merge 

func (m *ListSensorsRequest) XXX_Merge(src proto.Message)

func (*ListSensorsRequest) XXX_Size 

func (m *ListSensorsRequest) XXX_Size() int

func (*ListSensorsRequest) XXX_Unmarshal 

func (m *ListSensorsRequest) XXX_Unmarshal(b []byte) error

type LogEntry 

type LogEntry struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	SensorName string `protobuf:"bytes,2,opt,name=sensorName,proto3" json:"sensorName,omitempty"`
	// optional - any trigger name
	TriggerName string   `protobuf:"bytes,3,opt,name=triggerName,proto3" json:"triggerName,omitempty"`
	Level       string   `protobuf:"bytes,5,opt,name=level,proto3" json:"level,omitempty"`
	Time        *v1.Time `protobuf:"bytes,6,opt,name=time,proto3" json:"time,omitempty"`
	Msg         string   `protobuf:"bytes,7,opt,name=msg,proto3" json:"msg,omitempty"`
	// optional - trigger dependency name
	DependencyName string `protobuf:"bytes,8,opt,name=dependencyName,proto3" json:"dependencyName,omitempty"`
	// optional - Cloud Event context
	EventContext         string   `protobuf:"bytes,9,opt,name=eventContext,proto3" json:"eventContext,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

structured log entry

func (*LogEntry) Descriptor 

func (*LogEntry) Descriptor() ([]byte, []int)

func (*LogEntry) GetDependencyName 

func (m *LogEntry) GetDependencyName() string

func (*LogEntry) GetEventContext 

func (m *LogEntry) GetEventContext() string

func (*LogEntry) GetLevel 

func (m *LogEntry) GetLevel() string

func (*LogEntry) GetMsg 

func (m *LogEntry) GetMsg() string

func (*LogEntry) GetNamespace 

func (m *LogEntry) GetNamespace() string

func (*LogEntry) GetSensorName 

func (m *LogEntry) GetSensorName() string

func (*LogEntry) GetTime 

func (m *LogEntry) GetTime() *v1.Time

func (*LogEntry) GetTriggerName 

func (m *LogEntry) GetTriggerName() string

func (*LogEntry) Marshal 

func (m *LogEntry) Marshal() (dAtA []byte, err error)

func (*LogEntry) MarshalTo 

func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*LogEntry) MarshalToSizedBuffer 

func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

func (m *LogEntry) Size() (n int)

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

func (m *LogEntry) Unmarshal(dAtA []byte) error

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge 

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type SensorServiceClient 

type SensorServiceClient interface {
	ListSensors(ctx context.Context, in *ListSensorsRequest, opts ...grpc.CallOption) (*v1alpha1.SensorList, error)
	SensorsLogs(ctx context.Context, in *SensorsLogsRequest, opts ...grpc.CallOption) (SensorService_SensorsLogsClient, error)
	WatchSensors(ctx context.Context, in *ListSensorsRequest, opts ...grpc.CallOption) (SensorService_WatchSensorsClient, error)
	CreateSensor(ctx context.Context, in *CreateSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error)
	UpdateSensor(ctx context.Context, in *UpdateSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error)
	DeleteSensor(ctx context.Context, in *DeleteSensorRequest, opts ...grpc.CallOption) (*DeleteSensorResponse, error)
	GetSensor(ctx context.Context, in *GetSensorRequest, opts ...grpc.CallOption) (*v1alpha1.Sensor, error)
}

SensorServiceClient is the client API for SensorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSensorServiceClient 

func NewSensorServiceClient(cc *grpc.ClientConn) SensorServiceClient

type SensorServiceServer 

type SensorServiceServer interface {
	ListSensors(context.Context, *ListSensorsRequest) (*v1alpha1.SensorList, error)
	SensorsLogs(*SensorsLogsRequest, SensorService_SensorsLogsServer) error
	WatchSensors(*ListSensorsRequest, SensorService_WatchSensorsServer) error
	CreateSensor(context.Context, *CreateSensorRequest) (*v1alpha1.Sensor, error)
	UpdateSensor(context.Context, *UpdateSensorRequest) (*v1alpha1.Sensor, error)
	DeleteSensor(context.Context, *DeleteSensorRequest) (*DeleteSensorResponse, error)
	GetSensor(context.Context, *GetSensorRequest) (*v1alpha1.Sensor, error)
}

SensorServiceServer is the server API for SensorService service.

type SensorService_SensorsLogsClient 

type SensorService_SensorsLogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type SensorService_SensorsLogsServer 

type SensorService_SensorsLogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type SensorService_WatchSensorsClient 

type SensorService_WatchSensorsClient interface {
	Recv() (*SensorWatchEvent, error)
	grpc.ClientStream
}

type SensorService_WatchSensorsServer 

type SensorService_WatchSensorsServer interface {
	Send(*SensorWatchEvent) error
	grpc.ServerStream
}

type SensorWatchEvent 

type SensorWatchEvent struct {
	Type                 string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Object               *v1alpha1.Sensor `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SensorWatchEvent) Descriptor 

func (*SensorWatchEvent) Descriptor() ([]byte, []int)

func (*SensorWatchEvent) GetObject 

func (m *SensorWatchEvent) GetObject() *v1alpha1.Sensor

func (*SensorWatchEvent) GetType 

func (m *SensorWatchEvent) GetType() string

func (*SensorWatchEvent) Marshal 

func (m *SensorWatchEvent) Marshal() (dAtA []byte, err error)

func (*SensorWatchEvent) MarshalTo 

func (m *SensorWatchEvent) MarshalTo(dAtA []byte) (int, error)

func (*SensorWatchEvent) MarshalToSizedBuffer 

func (m *SensorWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SensorWatchEvent) ProtoMessage 

func (*SensorWatchEvent) ProtoMessage()

func (*SensorWatchEvent) Reset 

func (m *SensorWatchEvent) Reset()

func (*SensorWatchEvent) Size 

func (m *SensorWatchEvent) Size() (n int)

func (*SensorWatchEvent) String 

func (m *SensorWatchEvent) String() string

func (*SensorWatchEvent) Unmarshal 

func (m *SensorWatchEvent) Unmarshal(dAtA []byte) error

func (*SensorWatchEvent) XXX_DiscardUnknown 

func (m *SensorWatchEvent) XXX_DiscardUnknown()

func (*SensorWatchEvent) XXX_Marshal 

func (m *SensorWatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SensorWatchEvent) XXX_Merge 

func (m *SensorWatchEvent) XXX_Merge(src proto.Message)

func (*SensorWatchEvent) XXX_Size 

func (m *SensorWatchEvent) XXX_Size() int

func (*SensorWatchEvent) XXX_Unmarshal 

func (m *SensorWatchEvent) XXX_Unmarshal(b []byte) error

type SensorsLogsRequest 

type SensorsLogsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// optional - only return entries for this sensor name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// optional - only return entries for this trigger
	TriggerName string `protobuf:"bytes,3,opt,name=triggerName,proto3" json:"triggerName,omitempty"`
	// option - only return entries where `msg` contains this regular expressions
	Grep                 string             `protobuf:"bytes,4,opt,name=grep,proto3" json:"grep,omitempty"`
	PodLogOptions        *v11.PodLogOptions `protobuf:"bytes,5,opt,name=podLogOptions,proto3" json:"podLogOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*SensorsLogsRequest) Descriptor 

func (*SensorsLogsRequest) Descriptor() ([]byte, []int)

func (*SensorsLogsRequest) GetGrep 

func (m *SensorsLogsRequest) GetGrep() string

func (*SensorsLogsRequest) GetName 

func (m *SensorsLogsRequest) GetName() string

func (*SensorsLogsRequest) GetNamespace 

func (m *SensorsLogsRequest) GetNamespace() string

func (*SensorsLogsRequest) GetPodLogOptions 

func (m *SensorsLogsRequest) GetPodLogOptions() *v11.PodLogOptions

func (*SensorsLogsRequest) GetTriggerName 

func (m *SensorsLogsRequest) GetTriggerName() string

func (*SensorsLogsRequest) Marshal 

func (m *SensorsLogsRequest) Marshal() (dAtA []byte, err error)

func (*SensorsLogsRequest) MarshalTo 

func (m *SensorsLogsRequest) MarshalTo(dAtA []byte) (int, error)

func (*SensorsLogsRequest) MarshalToSizedBuffer 

func (m *SensorsLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SensorsLogsRequest) ProtoMessage 

func (*SensorsLogsRequest) ProtoMessage()

func (*SensorsLogsRequest) Reset 

func (m *SensorsLogsRequest) Reset()

func (*SensorsLogsRequest) Size 

func (m *SensorsLogsRequest) Size() (n int)

func (*SensorsLogsRequest) String 

func (m *SensorsLogsRequest) String() string

func (*SensorsLogsRequest) Unmarshal 

func (m *SensorsLogsRequest) Unmarshal(dAtA []byte) error

func (*SensorsLogsRequest) XXX_DiscardUnknown 

func (m *SensorsLogsRequest) XXX_DiscardUnknown()

func (*SensorsLogsRequest) XXX_Marshal 

func (m *SensorsLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SensorsLogsRequest) XXX_Merge 

func (m *SensorsLogsRequest) XXX_Merge(src proto.Message)

func (*SensorsLogsRequest) XXX_Size 

func (m *SensorsLogsRequest) XXX_Size() int

func (*SensorsLogsRequest) XXX_Unmarshal 

func (m *SensorsLogsRequest) XXX_Unmarshal(b []byte) error

type UnimplementedSensorServiceServer 

type UnimplementedSensorServiceServer struct {
}

UnimplementedSensorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSensorServiceServer) CreateSensor 

func (*UnimplementedSensorServiceServer) CreateSensor(ctx context.Context, req *CreateSensorRequest) (*v1alpha1.Sensor, error)

func (*UnimplementedSensorServiceServer) DeleteSensor 

func (*UnimplementedSensorServiceServer) DeleteSensor(ctx context.Context, req *DeleteSensorRequest) (*DeleteSensorResponse, error)

func (*UnimplementedSensorServiceServer) GetSensor 

func (*UnimplementedSensorServiceServer) GetSensor(ctx context.Context, req *GetSensorRequest) (*v1alpha1.Sensor, error)

func (*UnimplementedSensorServiceServer) ListSensors 

func (*UnimplementedSensorServiceServer) ListSensors(ctx context.Context, req *ListSensorsRequest) (*v1alpha1.SensorList, error)

func (*UnimplementedSensorServiceServer) SensorsLogs 

func (*UnimplementedSensorServiceServer) SensorsLogs(req *SensorsLogsRequest, srv SensorService_SensorsLogsServer) error

func (*UnimplementedSensorServiceServer) UpdateSensor 

func (*UnimplementedSensorServiceServer) UpdateSensor(ctx context.Context, req *UpdateSensorRequest) (*v1alpha1.Sensor, error)

func (*UnimplementedSensorServiceServer) WatchSensors 

func (*UnimplementedSensorServiceServer) WatchSensors(req *ListSensorsRequest, srv SensorService_WatchSensorsServer) error

type UpdateSensorRequest 

type UpdateSensorRequest struct {
	Namespace            string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Sensor               *v1alpha1.Sensor `protobuf:"bytes,3,opt,name=sensor,proto3" json:"sensor,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*UpdateSensorRequest) Descriptor 

func (*UpdateSensorRequest) Descriptor() ([]byte, []int)

func (*UpdateSensorRequest) GetName 

func (m *UpdateSensorRequest) GetName() string

func (*UpdateSensorRequest) GetNamespace 

func (m *UpdateSensorRequest) GetNamespace() string

func (*UpdateSensorRequest) GetSensor 

func (m *UpdateSensorRequest) GetSensor() *v1alpha1.Sensor

func (*UpdateSensorRequest) Marshal 

func (m *UpdateSensorRequest) Marshal() (dAtA []byte, err error)

func (*UpdateSensorRequest) MarshalTo 

func (m *UpdateSensorRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateSensorRequest) MarshalToSizedBuffer 

func (m *UpdateSensorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateSensorRequest) ProtoMessage 

func (*UpdateSensorRequest) ProtoMessage()

func (*UpdateSensorRequest) Reset 

func (m *UpdateSensorRequest) Reset()

func (*UpdateSensorRequest) Size 

func (m *UpdateSensorRequest) Size() (n int)

func (*UpdateSensorRequest) String 

func (m *UpdateSensorRequest) String() string

func (*UpdateSensorRequest) Unmarshal 

func (m *UpdateSensorRequest) Unmarshal(dAtA []byte) error

func (*UpdateSensorRequest) XXX_DiscardUnknown 

func (m *UpdateSensorRequest) XXX_DiscardUnknown()

func (*UpdateSensorRequest) XXX_Marshal 

func (m *UpdateSensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSensorRequest) XXX_Merge 

func (m *UpdateSensorRequest) XXX_Merge(src proto.Message)

func (*UpdateSensorRequest) XXX_Size 

func (m *UpdateSensorRequest) XXX_Size() int

func (*UpdateSensorRequest) XXX_Unmarshal 

func (m *UpdateSensorRequest) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.