Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + var ErrIntOverflowEventsource = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEventsource = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEventsource = fmt.Errorf("proto: unexpected end of group") + func RegisterEventSourceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterEventSourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventSourceServiceClient) error + func RegisterEventSourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterEventSourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventSourceServiceServer) error + func RegisterEventSourceServiceServer(s *grpc.Server, srv EventSourceServiceServer) + type CreateEventSourceRequest struct + EventSource *v1alpha1.EventSource + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEventSourceRequest) Descriptor() ([]byte, []int) + func (*CreateEventSourceRequest) ProtoMessage() + func (m *CreateEventSourceRequest) GetEventSource() *v1alpha1.EventSource + func (m *CreateEventSourceRequest) GetNamespace() string + func (m *CreateEventSourceRequest) Marshal() (dAtA []byte, err error) + func (m *CreateEventSourceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateEventSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateEventSourceRequest) Reset() + func (m *CreateEventSourceRequest) Size() (n int) + func (m *CreateEventSourceRequest) String() string + func (m *CreateEventSourceRequest) Unmarshal(dAtA []byte) error + func (m *CreateEventSourceRequest) XXX_DiscardUnknown() + func (m *CreateEventSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEventSourceRequest) XXX_Merge(src proto.Message) + func (m *CreateEventSourceRequest) XXX_Size() int + func (m *CreateEventSourceRequest) XXX_Unmarshal(b []byte) error + type DeleteEventSourceRequest struct + DeleteOptions *v1.DeleteOptions + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteEventSourceRequest) Descriptor() ([]byte, []int) + func (*DeleteEventSourceRequest) ProtoMessage() + func (m *DeleteEventSourceRequest) GetDeleteOptions() *v1.DeleteOptions + func (m *DeleteEventSourceRequest) GetName() string + func (m *DeleteEventSourceRequest) GetNamespace() string + func (m *DeleteEventSourceRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteEventSourceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteEventSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteEventSourceRequest) Reset() + func (m *DeleteEventSourceRequest) Size() (n int) + func (m *DeleteEventSourceRequest) String() string + func (m *DeleteEventSourceRequest) Unmarshal(dAtA []byte) error + func (m *DeleteEventSourceRequest) XXX_DiscardUnknown() + func (m *DeleteEventSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteEventSourceRequest) XXX_Merge(src proto.Message) + func (m *DeleteEventSourceRequest) XXX_Size() int + func (m *DeleteEventSourceRequest) XXX_Unmarshal(b []byte) error + type EventSourceDeletedResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventSourceDeletedResponse) Descriptor() ([]byte, []int) + func (*EventSourceDeletedResponse) ProtoMessage() + func (m *EventSourceDeletedResponse) Marshal() (dAtA []byte, err error) + func (m *EventSourceDeletedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceDeletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceDeletedResponse) Reset() + func (m *EventSourceDeletedResponse) Size() (n int) + func (m *EventSourceDeletedResponse) String() string + func (m *EventSourceDeletedResponse) Unmarshal(dAtA []byte) error + func (m *EventSourceDeletedResponse) XXX_DiscardUnknown() + func (m *EventSourceDeletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceDeletedResponse) XXX_Merge(src proto.Message) + func (m *EventSourceDeletedResponse) XXX_Size() int + func (m *EventSourceDeletedResponse) XXX_Unmarshal(b []byte) error + type EventSourceServiceClient interface + CreateEventSource func(ctx context.Context, in *CreateEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error) + DeleteEventSource func(ctx context.Context, in *DeleteEventSourceRequest, opts ...grpc.CallOption) (*EventSourceDeletedResponse, error) + EventSourcesLogs func(ctx context.Context, in *EventSourcesLogsRequest, opts ...grpc.CallOption) (EventSourceService_EventSourcesLogsClient, error) + GetEventSource func(ctx context.Context, in *GetEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error) + ListEventSources func(ctx context.Context, in *ListEventSourcesRequest, opts ...grpc.CallOption) (*v1alpha1.EventSourceList, error) + UpdateEventSource func(ctx context.Context, in *UpdateEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error) + WatchEventSources func(ctx context.Context, in *ListEventSourcesRequest, opts ...grpc.CallOption) (EventSourceService_WatchEventSourcesClient, error) + func NewEventSourceServiceClient(cc *grpc.ClientConn) EventSourceServiceClient + type EventSourceServiceServer interface + CreateEventSource func(context.Context, *CreateEventSourceRequest) (*v1alpha1.EventSource, error) + DeleteEventSource func(context.Context, *DeleteEventSourceRequest) (*EventSourceDeletedResponse, error) + EventSourcesLogs func(*EventSourcesLogsRequest, EventSourceService_EventSourcesLogsServer) error + GetEventSource func(context.Context, *GetEventSourceRequest) (*v1alpha1.EventSource, error) + ListEventSources func(context.Context, *ListEventSourcesRequest) (*v1alpha1.EventSourceList, error) + UpdateEventSource func(context.Context, *UpdateEventSourceRequest) (*v1alpha1.EventSource, error) + WatchEventSources func(*ListEventSourcesRequest, EventSourceService_WatchEventSourcesServer) error + type EventSourceService_EventSourcesLogsClient interface + Recv func() (*LogEntry, error) + type EventSourceService_EventSourcesLogsServer interface + Send func(*LogEntry) error + type EventSourceService_WatchEventSourcesClient interface + Recv func() (*EventSourceWatchEvent, error) + type EventSourceService_WatchEventSourcesServer interface + Send func(*EventSourceWatchEvent) error + type EventSourceWatchEvent struct + Object *v1alpha1.EventSource + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventSourceWatchEvent) Descriptor() ([]byte, []int) + func (*EventSourceWatchEvent) ProtoMessage() + func (m *EventSourceWatchEvent) GetObject() *v1alpha1.EventSource + func (m *EventSourceWatchEvent) GetType() string + func (m *EventSourceWatchEvent) Marshal() (dAtA []byte, err error) + func (m *EventSourceWatchEvent) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceWatchEvent) Reset() + func (m *EventSourceWatchEvent) Size() (n int) + func (m *EventSourceWatchEvent) String() string + func (m *EventSourceWatchEvent) Unmarshal(dAtA []byte) error + func (m *EventSourceWatchEvent) XXX_DiscardUnknown() + func (m *EventSourceWatchEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceWatchEvent) XXX_Merge(src proto.Message) + func (m *EventSourceWatchEvent) XXX_Size() int + func (m *EventSourceWatchEvent) XXX_Unmarshal(b []byte) error + type EventSourcesLogsRequest struct + EventName string + EventSourceType string + Grep string + Name string + Namespace string + PodLogOptions *v11.PodLogOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventSourcesLogsRequest) Descriptor() ([]byte, []int) + func (*EventSourcesLogsRequest) ProtoMessage() + func (m *EventSourcesLogsRequest) GetEventName() string + func (m *EventSourcesLogsRequest) GetEventSourceType() string + func (m *EventSourcesLogsRequest) GetGrep() string + func (m *EventSourcesLogsRequest) GetName() string + func (m *EventSourcesLogsRequest) GetNamespace() string + func (m *EventSourcesLogsRequest) GetPodLogOptions() *v11.PodLogOptions + func (m *EventSourcesLogsRequest) Marshal() (dAtA []byte, err error) + func (m *EventSourcesLogsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourcesLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourcesLogsRequest) Reset() + func (m *EventSourcesLogsRequest) Size() (n int) + func (m *EventSourcesLogsRequest) String() string + func (m *EventSourcesLogsRequest) Unmarshal(dAtA []byte) error + func (m *EventSourcesLogsRequest) XXX_DiscardUnknown() + func (m *EventSourcesLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourcesLogsRequest) XXX_Merge(src proto.Message) + func (m *EventSourcesLogsRequest) XXX_Size() int + func (m *EventSourcesLogsRequest) XXX_Unmarshal(b []byte) error + type GetEventSourceRequest struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetEventSourceRequest) Descriptor() ([]byte, []int) + func (*GetEventSourceRequest) ProtoMessage() + func (m *GetEventSourceRequest) GetName() string + func (m *GetEventSourceRequest) GetNamespace() string + func (m *GetEventSourceRequest) Marshal() (dAtA []byte, err error) + func (m *GetEventSourceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetEventSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetEventSourceRequest) Reset() + func (m *GetEventSourceRequest) Size() (n int) + func (m *GetEventSourceRequest) String() string + func (m *GetEventSourceRequest) Unmarshal(dAtA []byte) error + func (m *GetEventSourceRequest) XXX_DiscardUnknown() + func (m *GetEventSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetEventSourceRequest) XXX_Merge(src proto.Message) + func (m *GetEventSourceRequest) XXX_Size() int + func (m *GetEventSourceRequest) XXX_Unmarshal(b []byte) error + type ListEventSourcesRequest struct + ListOptions *v1.ListOptions + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListEventSourcesRequest) Descriptor() ([]byte, []int) + func (*ListEventSourcesRequest) ProtoMessage() + func (m *ListEventSourcesRequest) GetListOptions() *v1.ListOptions + func (m *ListEventSourcesRequest) GetNamespace() string + func (m *ListEventSourcesRequest) Marshal() (dAtA []byte, err error) + func (m *ListEventSourcesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListEventSourcesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListEventSourcesRequest) Reset() + func (m *ListEventSourcesRequest) Size() (n int) + func (m *ListEventSourcesRequest) String() string + func (m *ListEventSourcesRequest) Unmarshal(dAtA []byte) error + func (m *ListEventSourcesRequest) XXX_DiscardUnknown() + func (m *ListEventSourcesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListEventSourcesRequest) XXX_Merge(src proto.Message) + func (m *ListEventSourcesRequest) XXX_Size() int + func (m *ListEventSourcesRequest) XXX_Unmarshal(b []byte) error + type LogEntry struct + EventName string + EventSourceName string + EventSourceType string + Level string + Msg string + Namespace string + Time *v1.Time + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogEntry) Descriptor() ([]byte, []int) + func (*LogEntry) ProtoMessage() + func (m *LogEntry) GetEventName() string + func (m *LogEntry) GetEventSourceName() string + func (m *LogEntry) GetEventSourceType() string + func (m *LogEntry) GetLevel() string + func (m *LogEntry) GetMsg() string + func (m *LogEntry) GetNamespace() string + func (m *LogEntry) GetTime() *v1.Time + 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 UnimplementedEventSourceServiceServer struct + func (*UnimplementedEventSourceServiceServer) CreateEventSource(ctx context.Context, req *CreateEventSourceRequest) (*v1alpha1.EventSource, error) + func (*UnimplementedEventSourceServiceServer) DeleteEventSource(ctx context.Context, req *DeleteEventSourceRequest) (*EventSourceDeletedResponse, error) + func (*UnimplementedEventSourceServiceServer) EventSourcesLogs(req *EventSourcesLogsRequest, srv EventSourceService_EventSourcesLogsServer) error + func (*UnimplementedEventSourceServiceServer) GetEventSource(ctx context.Context, req *GetEventSourceRequest) (*v1alpha1.EventSource, error) + func (*UnimplementedEventSourceServiceServer) ListEventSources(ctx context.Context, req *ListEventSourcesRequest) (*v1alpha1.EventSourceList, error) + func (*UnimplementedEventSourceServiceServer) UpdateEventSource(ctx context.Context, req *UpdateEventSourceRequest) (*v1alpha1.EventSource, error) + func (*UnimplementedEventSourceServiceServer) WatchEventSources(req *ListEventSourcesRequest, srv EventSourceService_WatchEventSourcesServer) error + type UpdateEventSourceRequest struct + EventSource *v1alpha1.EventSource + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateEventSourceRequest) Descriptor() ([]byte, []int) + func (*UpdateEventSourceRequest) ProtoMessage() + func (m *UpdateEventSourceRequest) GetEventSource() *v1alpha1.EventSource + func (m *UpdateEventSourceRequest) GetName() string + func (m *UpdateEventSourceRequest) GetNamespace() string + func (m *UpdateEventSourceRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateEventSourceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateEventSourceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateEventSourceRequest) Reset() + func (m *UpdateEventSourceRequest) Size() (n int) + func (m *UpdateEventSourceRequest) String() string + func (m *UpdateEventSourceRequest) Unmarshal(dAtA []byte) error + func (m *UpdateEventSourceRequest) XXX_DiscardUnknown() + func (m *UpdateEventSourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateEventSourceRequest) XXX_Merge(src proto.Message) + func (m *UpdateEventSourceRequest) XXX_Size() int + func (m *UpdateEventSourceRequest) XXX_Unmarshal(b []byte) error
Go to main page