Documentation
¶
Index ¶
Constants ¶
const (
APIVersion = "v1"
)
APIVersion of the `fabriceventstream` CRD
Variables ¶
var (
AddToScheme = schemeBuilder.AddToScheme
)
var SchemeGroupVersion = schema.GroupVersion{Group: "cosmic.rocks", Version: APIVersion}
SchemeGroupVersion is the group version used to register these objects.
Functions ¶
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes an unqualified resource and returns a Group-qualified GroupResource.
Types ¶
type Connection ¶
type Connection struct {
Url string `json:"jdbcUrl"`
SlotName string `json:"slotName"`
PluginType string `json:"pluginType,omitempty"`
PublicationName *string `json:"publicationName,omitempty"`
DBAuth DBAuth `json:"databaseAuthentication"`
}
Connection to be used for allowing the FES operator to connect to a database
func (*Connection) DeepCopy ¶
func (in *Connection) DeepCopy() *Connection
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Connection) DeepCopyInto ¶
func (in *Connection) DeepCopyInto(out *Connection)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type DBAuth ¶
type DBAuth struct {
Type string `json:"type"`
Name string `json:"name,omitempty"`
UserKey string `json:"userKey,omitempty"`
PasswordKey string `json:"passwordKey,omitempty"`
}
DBAuth specifies the credentials to be used for connecting with the database
func (*DBAuth) DeepCopy ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*DBAuth) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStream ¶
type EventStream struct {
EventStreamFlow EventStreamFlow `json:"flow"`
EventStreamSink EventStreamSink `json:"sink"`
EventStreamSource EventStreamSource `json:"source"`
}
EventStream defines the source, flow and sink of the event stream
func (*EventStream) DeepCopy ¶
func (in *EventStream) DeepCopy() *EventStream
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStream) DeepCopyInto ¶
func (in *EventStream) DeepCopyInto(out *EventStream)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStreamFlow ¶
type EventStreamFlow struct {
Type string `json:"type"`
PayloadColumn *string `json:"payloadColumn,omitempty"`
}
EventStreamFlow defines the flow characteristics of the event stream
func (*EventStreamFlow) DeepCopy ¶
func (in *EventStreamFlow) DeepCopy() *EventStreamFlow
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStreamFlow) DeepCopyInto ¶
func (in *EventStreamFlow) DeepCopyInto(out *EventStreamFlow)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStreamSink ¶
type EventStreamSink struct {
Type string `json:"type"`
EventType string `json:"eventType,omitempty"`
MaxBatchSize *uint32 `json:"maxBatchSize,omitempty"`
}
EventStreamSink defines the target of the event stream
func (*EventStreamSink) DeepCopy ¶
func (in *EventStreamSink) DeepCopy() *EventStreamSink
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStreamSink) DeepCopyInto ¶
func (in *EventStreamSink) DeepCopyInto(out *EventStreamSink)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStreamSource ¶
type EventStreamSource struct {
Type string `json:"type"`
Schema string `json:"schema,omitempty" defaults:"public"`
EventStreamTable EventStreamTable `json:"table"`
Filter *string `json:"filter,omitempty"`
Connection Connection `json:"jdbcConnection"`
}
EventStreamSource defines the source of the event stream and connection for FES operator
func (*EventStreamSource) DeepCopy ¶
func (in *EventStreamSource) DeepCopy() *EventStreamSource
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStreamSource) DeepCopyInto ¶
func (in *EventStreamSource) DeepCopyInto(out *EventStreamSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EventStreamTable ¶
type EventStreamTable struct {
Name string `json:"name"`
IDColumn *string `json:"idColumn,omitempty"`
}
EventStreamTable defines the name and ID column to be used for streaming
func (*EventStreamTable) DeepCopy ¶
func (in *EventStreamTable) DeepCopy() *EventStreamTable
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventStreamTable) DeepCopyInto ¶
func (in *EventStreamTable) DeepCopyInto(out *EventStreamTable)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FabricEventStream ¶
type FabricEventStream struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec FabricEventStreamSpec `json:"spec"`
}
FabricEventStream defines FabricEventStream Custom Resource Definition Object.
func (*FabricEventStream) DeepCopy ¶
func (in *FabricEventStream) DeepCopy() *FabricEventStream
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FabricEventStream.
func (*FabricEventStream) DeepCopyInto ¶
func (in *FabricEventStream) DeepCopyInto(out *FabricEventStream)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FabricEventStream) DeepCopyObject ¶
func (in *FabricEventStream) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type FabricEventStreamList ¶
type FabricEventStreamList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata"`
Items []FabricEventStream `json:"items"`
}
FabricEventStreamList defines a list of FabricEventStreams .
func (*FabricEventStreamList) DeepCopy ¶
func (in *FabricEventStreamList) DeepCopy() *FabricEventStreamList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FabricEventStreamList.
func (*FabricEventStreamList) DeepCopyInto ¶
func (in *FabricEventStreamList) DeepCopyInto(out *FabricEventStreamList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FabricEventStreamList) DeepCopyObject ¶
func (in *FabricEventStreamList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type FabricEventStreamSpec ¶
type FabricEventStreamSpec struct {
ApplicationId string `json:"applicationId"`
EventStreams []EventStream `json:"eventStreams"`
}
FabricEventStreamSpec defines the specification for the FabricEventStream TPR.
func (*FabricEventStreamSpec) DeepCopy ¶
func (in *FabricEventStreamSpec) DeepCopy() *FabricEventStreamSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FabricEventStreamSpec.
func (*FabricEventStreamSpec) DeepCopyInto ¶
func (in *FabricEventStreamSpec) DeepCopyInto(out *FabricEventStreamSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files