kafka
No long description provided.
Installation
dagger install github.com/sagikazarmark/daggerverse/kafka@93d0e7724f12e78d6f9c3917d4e1f52812e9b5c1
Entrypoint
Return Type
Kafka
Example
func (m *myModule) example() *Kafka {
return dag.
Kafka()
}
@function
def example() -> dag.Kafka:
return (
dag.kafka()
)
@func()
example(): Kafka {
return dag
.kafka()
}
Types
Kafka 🔗
withVersion() 🔗
Specify which version of Kafka to use.
Return Type
KafkaContainer !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
version | StringKind ! | - | No description provided |
Example
Function Kafka.withVersion is not accessible from the kafka module
func (m *myModule) example(version ) {
return dag.
Kafka().
WithVersion(version)
}
@function
def example(version: ) -> :
return (
dag.kafka()
.with_version(version)
)
@func()
example(version: ): {
return dag
.kafka()
.withVersion(version)
}
withImageRef() 🔗
Specify a custom image reference in “repository:tag” format.
Note: this module expects an image compatible with bitnami/kafka.
Return Type
KafkaContainer !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
ref | StringKind ! | - | No description provided |
Example
Function Kafka.withImageRef is not accessible from the kafka module
func (m *myModule) example(ref ) {
return dag.
Kafka().
WithImageRef(ref)
}
@function
def example(ref: ) -> :
return (
dag.kafka()
.with_image_ref(ref)
)
@func()
example(ref: ): {
return dag
.kafka()
.withImageRef(ref)
}
withContainer() 🔗
Specify a custom container.
Note: this module expects an image compatible with bitnami/kafka.
Return Type
KafkaContainer !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
ctr | Container ! | - | No description provided |
Example
Function Kafka.withContainer is not accessible from the kafka module
func (m *myModule) example(ctr ) {
return dag.
Kafka().
WithContainer(ctr)
}
@function
def example(ctr: ) -> :
return (
dag.kafka()
.with_container(ctr)
)
@func()
example(ctr: ): {
return dag
.kafka()
.withContainer(ctr)
}
container() 🔗
Return the default container.
Return Type
Container !
Example
Function Kafka.container is not accessible from the kafka module
func (m *myModule) example() {
return dag.
Kafka().
Container()
}
@function
def example() -> :
return (
dag.kafka()
.container()
)
@func()
example(): {
return dag
.kafka()
.container()
}
service() 🔗
Launch a Kafka service using the default container.
Return Type
Service !
Example
Function Kafka.service is not accessible from the kafka module
func (m *myModule) example() {
return dag.
Kafka().
Service()
}
@function
def example() -> :
return (
dag.kafka()
.service()
)
@func()
example(): {
return dag
.kafka()
.service()
}
KafkaContainer 🔗
ctr() 🔗
Return Type
Container !
Example
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
Function KafkaKafkaContainer.Ctr is not accessible from the kafka module
container() 🔗
Return the default container.
Return Type
Container !
Example
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module
Function KafkaKafkaContainer.container is not accessible from the kafka module
service() 🔗
Launch a Kafka service using the default container.
Return Type
Service !
Example
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module
Function KafkaKafkaContainer.service is not accessible from the kafka module