eventsource

package
v3.0.0-...-8a51905 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package eventsource is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEventsource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEventsource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEventsource = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterEventSourceServiceHandler 

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

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

func RegisterEventSourceServiceHandlerClient 

func RegisterEventSourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventSourceServiceClient) error

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

func RegisterEventSourceServiceHandlerFromEndpoint 

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

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

func RegisterEventSourceServiceHandlerServer 

func RegisterEventSourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventSourceServiceServer) error

RegisterEventSourceServiceHandlerServer registers the http handlers for service EventSourceService to "mux". UnaryRPC :call EventSourceServiceServer 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 RegisterEventSourceServiceHandlerFromEndpoint instead.

func RegisterEventSourceServiceServer 

func RegisterEventSourceServiceServer(s *grpc.Server, srv EventSourceServiceServer)

Types

type CreateEventSourceRequest 

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

func (*CreateEventSourceRequest) Descriptor 

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

func (*CreateEventSourceRequest) GetEventSource 

func (m *CreateEventSourceRequest) GetEventSource() *v1alpha1.EventSource

func (*CreateEventSourceRequest) GetNamespace 

func (m *CreateEventSourceRequest) GetNamespace() string

func (*CreateEventSourceRequest) Marshal 

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

func (*CreateEventSourceRequest) MarshalTo 

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

func (*CreateEventSourceRequest) MarshalToSizedBuffer 

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

func (*CreateEventSourceRequest) ProtoMessage 

func (*CreateEventSourceRequest) ProtoMessage()

func (*CreateEventSourceRequest) Reset 

func (m *CreateEventSourceRequest) Reset()

func (*CreateEventSourceRequest) Size 

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

func (*CreateEventSourceRequest) String 

func (m *CreateEventSourceRequest) String() string

func (*CreateEventSourceRequest) Unmarshal 

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

func (*CreateEventSourceRequest) XXX_DiscardUnknown 

func (m *CreateEventSourceRequest) XXX_DiscardUnknown()

func (*CreateEventSourceRequest) XXX_Marshal 

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

func (*CreateEventSourceRequest) XXX_Merge 

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

func (*CreateEventSourceRequest) XXX_Size 

func (m *CreateEventSourceRequest) XXX_Size() int

func (*CreateEventSourceRequest) XXX_Unmarshal 

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

type DeleteEventSourceRequest 

type DeleteEventSourceRequest 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 (*DeleteEventSourceRequest) Descriptor 

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

func (*DeleteEventSourceRequest) GetDeleteOptions 

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

func (*DeleteEventSourceRequest) GetName 

func (m *DeleteEventSourceRequest) GetName() string

func (*DeleteEventSourceRequest) GetNamespace 

func (m *DeleteEventSourceRequest) GetNamespace() string

func (*DeleteEventSourceRequest) Marshal 

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

func (*DeleteEventSourceRequest) MarshalTo 

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

func (*DeleteEventSourceRequest) MarshalToSizedBuffer 

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

func (*DeleteEventSourceRequest) ProtoMessage 

func (*DeleteEventSourceRequest) ProtoMessage()

func (*DeleteEventSourceRequest) Reset 

func (m *DeleteEventSourceRequest) Reset()

func (*DeleteEventSourceRequest) Size 

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

func (*DeleteEventSourceRequest) String 

func (m *DeleteEventSourceRequest) String() string

func (*DeleteEventSourceRequest) Unmarshal 

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

func (*DeleteEventSourceRequest) XXX_DiscardUnknown 

func (m *DeleteEventSourceRequest) XXX_DiscardUnknown()

func (*DeleteEventSourceRequest) XXX_Marshal 

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

func (*DeleteEventSourceRequest) XXX_Merge 

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

func (*DeleteEventSourceRequest) XXX_Size 

func (m *DeleteEventSourceRequest) XXX_Size() int

func (*DeleteEventSourceRequest) XXX_Unmarshal 

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

type EventSourceDeletedResponse 

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

func (*EventSourceDeletedResponse) Descriptor 

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

func (*EventSourceDeletedResponse) Marshal 

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

func (*EventSourceDeletedResponse) MarshalTo 

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

func (*EventSourceDeletedResponse) MarshalToSizedBuffer 

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

func (*EventSourceDeletedResponse) ProtoMessage 

func (*EventSourceDeletedResponse) ProtoMessage()

func (*EventSourceDeletedResponse) Reset 

func (m *EventSourceDeletedResponse) Reset()

func (*EventSourceDeletedResponse) Size 

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

func (*EventSourceDeletedResponse) String 

func (m *EventSourceDeletedResponse) String() string

func (*EventSourceDeletedResponse) Unmarshal 

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

func (*EventSourceDeletedResponse) XXX_DiscardUnknown 

func (m *EventSourceDeletedResponse) XXX_DiscardUnknown()

func (*EventSourceDeletedResponse) XXX_Marshal 

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

func (*EventSourceDeletedResponse) XXX_Merge 

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

func (*EventSourceDeletedResponse) XXX_Size 

func (m *EventSourceDeletedResponse) XXX_Size() int

func (*EventSourceDeletedResponse) XXX_Unmarshal 

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

type EventSourceServiceClient 

type EventSourceServiceClient interface {
	CreateEventSource(ctx context.Context, in *CreateEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error)
	GetEventSource(ctx context.Context, in *GetEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error)
	DeleteEventSource(ctx context.Context, in *DeleteEventSourceRequest, opts ...grpc.CallOption) (*EventSourceDeletedResponse, error)
	UpdateEventSource(ctx context.Context, in *UpdateEventSourceRequest, opts ...grpc.CallOption) (*v1alpha1.EventSource, error)
	ListEventSources(ctx context.Context, in *ListEventSourcesRequest, opts ...grpc.CallOption) (*v1alpha1.EventSourceList, error)
	EventSourcesLogs(ctx context.Context, in *EventSourcesLogsRequest, opts ...grpc.CallOption) (EventSourceService_EventSourcesLogsClient, error)
	WatchEventSources(ctx context.Context, in *ListEventSourcesRequest, opts ...grpc.CallOption) (EventSourceService_WatchEventSourcesClient, error)
}

EventSourceServiceClient is the client API for EventSourceService service.

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

func NewEventSourceServiceClient 

func NewEventSourceServiceClient(cc *grpc.ClientConn) EventSourceServiceClient

type EventSourceServiceServer 

type EventSourceServiceServer interface {
	CreateEventSource(context.Context, *CreateEventSourceRequest) (*v1alpha1.EventSource, error)
	GetEventSource(context.Context, *GetEventSourceRequest) (*v1alpha1.EventSource, error)
	DeleteEventSource(context.Context, *DeleteEventSourceRequest) (*EventSourceDeletedResponse, error)
	UpdateEventSource(context.Context, *UpdateEventSourceRequest) (*v1alpha1.EventSource, error)
	ListEventSources(context.Context, *ListEventSourcesRequest) (*v1alpha1.EventSourceList, error)
	EventSourcesLogs(*EventSourcesLogsRequest, EventSourceService_EventSourcesLogsServer) error
	WatchEventSources(*ListEventSourcesRequest, EventSourceService_WatchEventSourcesServer) error
}

EventSourceServiceServer is the server API for EventSourceService service.

type EventSourceService_EventSourcesLogsClient 

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

type EventSourceService_EventSourcesLogsServer 

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

type EventSourceService_WatchEventSourcesClient 

type EventSourceService_WatchEventSourcesClient interface {
	Recv() (*EventSourceWatchEvent, error)
	grpc.ClientStream
}

type EventSourceService_WatchEventSourcesServer 

type EventSourceService_WatchEventSourcesServer interface {
	Send(*EventSourceWatchEvent) error
	grpc.ServerStream
}

type EventSourceWatchEvent 

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

func (*EventSourceWatchEvent) Descriptor 

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

func (*EventSourceWatchEvent) GetObject 

func (m *EventSourceWatchEvent) GetObject() *v1alpha1.EventSource

func (*EventSourceWatchEvent) GetType 

func (m *EventSourceWatchEvent) GetType() string

func (*EventSourceWatchEvent) Marshal 

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

func (*EventSourceWatchEvent) MarshalTo 

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

func (*EventSourceWatchEvent) MarshalToSizedBuffer 

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

func (*EventSourceWatchEvent) ProtoMessage 

func (*EventSourceWatchEvent) ProtoMessage()

func (*EventSourceWatchEvent) Reset 

func (m *EventSourceWatchEvent) Reset()

func (*EventSourceWatchEvent) Size 

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

func (*EventSourceWatchEvent) String 

func (m *EventSourceWatchEvent) String() string

func (*EventSourceWatchEvent) Unmarshal 

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

func (*EventSourceWatchEvent) XXX_DiscardUnknown 

func (m *EventSourceWatchEvent) XXX_DiscardUnknown()

func (*EventSourceWatchEvent) XXX_Marshal 

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

func (*EventSourceWatchEvent) XXX_Merge 

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

func (*EventSourceWatchEvent) XXX_Size 

func (m *EventSourceWatchEvent) XXX_Size() int

func (*EventSourceWatchEvent) XXX_Unmarshal 

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

type EventSourcesLogsRequest 

type EventSourcesLogsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// optional - only return entries for this event source
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// optional - only return entries for this event source type (e.g. `webhook`)
	EventSourceType string `protobuf:"bytes,3,opt,name=eventSourceType,proto3" json:"eventSourceType,omitempty"`
	// optional - only return entries for this event name (e.g. `example`)
	EventName string `protobuf:"bytes,4,opt,name=eventName,proto3" json:"eventName,omitempty"`
	// optional - only return entries where `msg` matches this regular expression
	Grep                 string             `protobuf:"bytes,5,opt,name=grep,proto3" json:"grep,omitempty"`
	PodLogOptions        *v11.PodLogOptions `protobuf:"bytes,6,opt,name=podLogOptions,proto3" json:"podLogOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EventSourcesLogsRequest) Descriptor 

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

func (*EventSourcesLogsRequest) GetEventName 

func (m *EventSourcesLogsRequest) GetEventName() string

func (*EventSourcesLogsRequest) GetEventSourceType 

func (m *EventSourcesLogsRequest) GetEventSourceType() string

func (*EventSourcesLogsRequest) GetGrep 

func (m *EventSourcesLogsRequest) GetGrep() string

func (*EventSourcesLogsRequest) GetName 

func (m *EventSourcesLogsRequest) GetName() string

func (*EventSourcesLogsRequest) GetNamespace 

func (m *EventSourcesLogsRequest) GetNamespace() string

func (*EventSourcesLogsRequest) GetPodLogOptions 

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

func (*EventSourcesLogsRequest) Marshal 

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

func (*EventSourcesLogsRequest) MarshalTo 

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

func (*EventSourcesLogsRequest) MarshalToSizedBuffer 

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

func (*EventSourcesLogsRequest) ProtoMessage 

func (*EventSourcesLogsRequest) ProtoMessage()

func (*EventSourcesLogsRequest) Reset 

func (m *EventSourcesLogsRequest) Reset()

func (*EventSourcesLogsRequest) Size 

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

func (*EventSourcesLogsRequest) String 

func (m *EventSourcesLogsRequest) String() string

func (*EventSourcesLogsRequest) Unmarshal 

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

func (*EventSourcesLogsRequest) XXX_DiscardUnknown 

func (m *EventSourcesLogsRequest) XXX_DiscardUnknown()

func (*EventSourcesLogsRequest) XXX_Marshal 

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

func (*EventSourcesLogsRequest) XXX_Merge 

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

func (*EventSourcesLogsRequest) XXX_Size 

func (m *EventSourcesLogsRequest) XXX_Size() int

func (*EventSourcesLogsRequest) XXX_Unmarshal 

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

type GetEventSourceRequest 

type GetEventSourceRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetEventSourceRequest) Descriptor 

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

func (*GetEventSourceRequest) GetName 

func (m *GetEventSourceRequest) GetName() string

func (*GetEventSourceRequest) GetNamespace 

func (m *GetEventSourceRequest) GetNamespace() string

func (*GetEventSourceRequest) Marshal 

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

func (*GetEventSourceRequest) MarshalTo 

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

func (*GetEventSourceRequest) MarshalToSizedBuffer 

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

func (*GetEventSourceRequest) ProtoMessage 

func (*GetEventSourceRequest) ProtoMessage()

func (*GetEventSourceRequest) Reset 

func (m *GetEventSourceRequest) Reset()

func (*GetEventSourceRequest) Size 

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

func (*GetEventSourceRequest) String 

func (m *GetEventSourceRequest) String() string

func (*GetEventSourceRequest) Unmarshal 

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

func (*GetEventSourceRequest) XXX_DiscardUnknown 

func (m *GetEventSourceRequest) XXX_DiscardUnknown()

func (*GetEventSourceRequest) XXX_Marshal 

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

func (*GetEventSourceRequest) XXX_Merge 

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

func (*GetEventSourceRequest) XXX_Size 

func (m *GetEventSourceRequest) XXX_Size() int

func (*GetEventSourceRequest) XXX_Unmarshal 

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

type ListEventSourcesRequest 

type ListEventSourcesRequest 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 (*ListEventSourcesRequest) Descriptor 

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

func (*ListEventSourcesRequest) GetListOptions 

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

func (*ListEventSourcesRequest) GetNamespace 

func (m *ListEventSourcesRequest) GetNamespace() string

func (*ListEventSourcesRequest) Marshal 

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

func (*ListEventSourcesRequest) MarshalTo 

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

func (*ListEventSourcesRequest) MarshalToSizedBuffer 

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

func (*ListEventSourcesRequest) ProtoMessage 

func (*ListEventSourcesRequest) ProtoMessage()

func (*ListEventSourcesRequest) Reset 

func (m *ListEventSourcesRequest) Reset()

func (*ListEventSourcesRequest) Size 

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

func (*ListEventSourcesRequest) String 

func (m *ListEventSourcesRequest) String() string

func (*ListEventSourcesRequest) Unmarshal 

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

func (*ListEventSourcesRequest) XXX_DiscardUnknown 

func (m *ListEventSourcesRequest) XXX_DiscardUnknown()

func (*ListEventSourcesRequest) XXX_Marshal 

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

func (*ListEventSourcesRequest) XXX_Merge 

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

func (*ListEventSourcesRequest) XXX_Size 

func (m *ListEventSourcesRequest) XXX_Size() int

func (*ListEventSourcesRequest) XXX_Unmarshal 

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

type LogEntry 

type LogEntry struct {
	Namespace       string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	EventSourceName string `protobuf:"bytes,2,opt,name=eventSourceName,proto3" json:"eventSourceName,omitempty"`
	// optional - the event source type (e.g. `webhook`)
	EventSourceType string `protobuf:"bytes,3,opt,name=eventSourceType,proto3" json:"eventSourceType,omitempty"`
	// optional - the event name (e.g. `example`)
	EventName            string   `protobuf:"bytes,4,opt,name=eventName,proto3" json:"eventName,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"`
	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) GetEventName 

func (m *LogEntry) GetEventName() string

func (*LogEntry) GetEventSourceName 

func (m *LogEntry) GetEventSourceName() string

func (*LogEntry) GetEventSourceType 

func (m *LogEntry) GetEventSourceType() 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) GetTime 

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

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 UnimplementedEventSourceServiceServer 

type UnimplementedEventSourceServiceServer struct {
}

UnimplementedEventSourceServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventSourceServiceServer) CreateEventSource 

func (*UnimplementedEventSourceServiceServer) CreateEventSource(ctx context.Context, req *CreateEventSourceRequest) (*v1alpha1.EventSource, error)

func (*UnimplementedEventSourceServiceServer) DeleteEventSource 

func (*UnimplementedEventSourceServiceServer) DeleteEventSource(ctx context.Context, req *DeleteEventSourceRequest) (*EventSourceDeletedResponse, error)

func (*UnimplementedEventSourceServiceServer) EventSourcesLogs 

func (*UnimplementedEventSourceServiceServer) EventSourcesLogs(req *EventSourcesLogsRequest, srv EventSourceService_EventSourcesLogsServer) error

func (*UnimplementedEventSourceServiceServer) GetEventSource 

func (*UnimplementedEventSourceServiceServer) GetEventSource(ctx context.Context, req *GetEventSourceRequest) (*v1alpha1.EventSource, error)

func (*UnimplementedEventSourceServiceServer) ListEventSources 

func (*UnimplementedEventSourceServiceServer) ListEventSources(ctx context.Context, req *ListEventSourcesRequest) (*v1alpha1.EventSourceList, error)

func (*UnimplementedEventSourceServiceServer) UpdateEventSource 

func (*UnimplementedEventSourceServiceServer) UpdateEventSource(ctx context.Context, req *UpdateEventSourceRequest) (*v1alpha1.EventSource, error)

func (*UnimplementedEventSourceServiceServer) WatchEventSources 

func (*UnimplementedEventSourceServiceServer) WatchEventSources(req *ListEventSourcesRequest, srv EventSourceService_WatchEventSourcesServer) error

type UpdateEventSourceRequest 

type UpdateEventSourceRequest 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"`
	EventSource          *v1alpha1.EventSource `protobuf:"bytes,3,opt,name=eventSource,proto3" json:"eventSource,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UpdateEventSourceRequest) Descriptor 

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

func (*UpdateEventSourceRequest) GetEventSource 

func (m *UpdateEventSourceRequest) GetEventSource() *v1alpha1.EventSource

func (*UpdateEventSourceRequest) GetName 

func (m *UpdateEventSourceRequest) GetName() string

func (*UpdateEventSourceRequest) GetNamespace 

func (m *UpdateEventSourceRequest) GetNamespace() string

func (*UpdateEventSourceRequest) Marshal 

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

func (*UpdateEventSourceRequest) MarshalTo 

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

func (*UpdateEventSourceRequest) MarshalToSizedBuffer 

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

func (*UpdateEventSourceRequest) ProtoMessage 

func (*UpdateEventSourceRequest) ProtoMessage()

func (*UpdateEventSourceRequest) Reset 

func (m *UpdateEventSourceRequest) Reset()

func (*UpdateEventSourceRequest) Size 

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

func (*UpdateEventSourceRequest) String 

func (m *UpdateEventSourceRequest) String() string

func (*UpdateEventSourceRequest) Unmarshal 

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

func (*UpdateEventSourceRequest) XXX_DiscardUnknown 

func (m *UpdateEventSourceRequest) XXX_DiscardUnknown()

func (*UpdateEventSourceRequest) XXX_Marshal 

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

func (*UpdateEventSourceRequest) XXX_Merge 

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

func (*UpdateEventSourceRequest) XXX_Size 

func (m *UpdateEventSourceRequest) XXX_Size() int

func (*UpdateEventSourceRequest) XXX_Unmarshal 

func (m *UpdateEventSourceRequest) 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.