eventsource

package
v3.2.5 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2021 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

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

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) DeleteEventSource

func (*UnimplementedEventSourceServiceServer) EventSourcesLogs

func (*UnimplementedEventSourceServiceServer) GetEventSource

func (*UnimplementedEventSourceServiceServer) ListEventSources

func (*UnimplementedEventSourceServiceServer) UpdateEventSource

func (*UnimplementedEventSourceServiceServer) WatchEventSources

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL