Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // AnnotationIngestHash is the annotation key for the ingest hash value. AnnotationIngestHash = "k8s.mkz.io/grackle-ingest-hash" // DefaultGrackleImageName is the defualt image to use for Grackle. DefaultGrackleImageName = "quay.io/jmckind/grackle" // DefaultGrackleImageTag is the defualt tag to use for the Grackle image. DefaultGrackleImageTag = "latest" // DefaultWebReplicas is the number of Web UI pods to create by default. DefaultWebReplicas int32 = 2 // EnvOperatorPodName is the environment variable containig the operator pod name. EnvOperatorPodName = "POD_NAME" // LabelComponentKey is the key for the component label. LabelComponentKey = "component" // LabelComponentIngest is the ingest value for the component label. LabelComponentIngest = "ingest" // LabelComponentWeb is the web value for the component label. LabelComponentWeb = "web" )
Functions ¶
Types ¶
type IngestTrack ¶
type IngestTrack struct { // Checksum holds the checksum for the value. Checksum string `json:"checksum,omitempty"` // Value holds the actual search track value. Value string `json:"value,omitempty"` }
IngestTrack defines the value to track for a Twitter stream, which is a string containing a comma-delimited list of search terms.
func NewIngestTrack ¶
func NewIngestTrack(track string) *IngestTrack
NewIngestTrack will create a new IngestTrack from the given value.
type ReconcileGrackle ¶
type ReconcileGrackle struct {
// contains filtered or unexported fields
}
ReconcileGrackle reconciles a Grackle object
func (*ReconcileGrackle) Reconcile ¶
Reconcile reads that state of the cluster for a Grackle object and makes changes based on the state read and what is in the Grackle.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
Click to show internal directories.
Click to hide internal directories.