kafka
No long description provided.
Installation
dagger install github.com/sagikazarmark/daggerverse/kafka@08c16734109440b8e031b20b9aca195816857c4e
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 🔗
fromVersion() 🔗
Specify which version (image tag) of Kafka to use from the official image repository on Docker Hub.
Return Type
Base !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
version | StringKind ! | - | No description provided |
Example
Function Kafka.fromVersion is not accessible from the kafka module
func (m *myModule) example(version ) {
return dag.
Kafka().
FromVersion(version)
}
@function
def example(version: ) -> :
return (
dag.kafka()
.from_version(version)
)
@func()
example(version: ): {
return dag
.kafka()
.fromVersion(version)
}
fromImage() 🔗
Specify a custom image reference in “repository:tag” format.
Note: this module expects an image compatible with bitnami/kafka.
Return Type
Base !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
ref | StringKind ! | - | No description provided |
Example
Function Kafka.fromImage is not accessible from the kafka module
func (m *myModule) example(ref ) {
return dag.
Kafka().
FromImage(ref)
}
@function
def example(ref: ) -> :
return (
dag.kafka()
.from_image(ref)
)
@func()
example(ref: ): {
return dag
.kafka()
.fromImage(ref)
}
fromContainer() 🔗
Specify a custom container.
Note: this module expects an image compatible with bitnami/kafka.
Return Type
Base !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
ctr | Container ! | - | No description provided |
Example
Function Kafka.fromContainer is not accessible from the kafka module
func (m *myModule) example(ctr ) {
return dag.
Kafka().
FromContainer(ctr)
}
@function
def example(ctr: ) -> :
return (
dag.kafka()
.from_container(ctr)
)
@func()
example(ctr: ): {
return dag
.kafka()
.fromContainer(ctr)
}
withEnvVariable() 🔗
Set an environment variable.
Return Type
Base !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
name | StringKind ! | - | No description provided |
value | StringKind ! | - | No description provided |
expand | BooleanKind | - | No description provided |
Example
Function Kafka.withEnvVariable is not accessible from the kafka module
func (m *myModule) example(name , value ) {
return dag.
Kafka().
WithEnvVariable(name, value)
}
@function
def example(name: , value: ) -> :
return (
dag.kafka()
.with_env_variable(name, value)
)
@func()
example(name: , value: ): {
return dag
.kafka()
.withEnvVariable(name, value)
}
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()
}
Base 🔗
ctr() 🔗
Return Type
Container !
Example
Function KafkaBase.Ctr is not accessible from the kafka module
Function KafkaBase.Ctr is not accessible from the kafka module
Function KafkaBase.Ctr is not accessible from the kafka module
Function KafkaBase.Ctr is not accessible from the kafka module
container() 🔗
Return the default container.
Return Type
Container !
Example
Function KafkaBase.container is not accessible from the kafka module
Function KafkaBase.container is not accessible from the kafka module
Function KafkaBase.container is not accessible from the kafka module
Function KafkaBase.container is not accessible from the kafka module
withEnvVariable() 🔗
Set an environment variable.
Return Type
Base !
Arguments
Name | Type | Default Value | Description |
---|---|---|---|
name | StringKind ! | - | No description provided |
value | StringKind ! | - | No description provided |
expand | BooleanKind | - | No description provided |
Example
Function KafkaBase.withEnvVariable is not accessible from the kafka module
Function KafkaBase.withEnvVariable is not accessible from the kafka module
Function KafkaBase.withEnvVariable is not accessible from the kafka module
Function KafkaBase.withEnvVariable is not accessible from the kafka module
service() 🔗
Launch a Kafka service using the default container.
Return Type
Service !
Example
Function KafkaBase.service is not accessible from the kafka module
Function KafkaBase.service is not accessible from the kafka module
Function KafkaBase.service is not accessible from the kafka module
Function KafkaBase.service is not accessible from the kafka module