Documentation
¶
Index ¶
- Constants
- func CreateTopics(ctx context.Context, kafkaAddress string, topics []string) error
- func DefaultRegisterAndFetchProtos(ctx context.Context, client *github.Client, protoSchemaSets []ProtoSchemaSet, ...) error
- func DefaultSubjectNamingStrategy(subjectPrefix string, proto protoFile, protoSchemaSet ProtoSchemaSet) (string, error)
- func DeleteAllTopics(ctx context.Context, kafkaAddress string) error
- func RegisterAndFetchProtos(ctx context.Context, client *github.Client, protoSchemaSets []ProtoSchemaSet, ...) error
- func ValidateRepoConfiguration(repoConfig ProtoSchemaSet) error
- type ChipIngressOutput
- type Input
- type Output
- type ProtoSchemaSet
- type RedPandaOutput
- type RepositoryToSubjectNamingStrategyFn
- type SubjectNamingStrategyFn
Constants ¶
View Source
const ( DEFAULT_STACK_NAME = "chip-ingress" DEFAULT_CHIP_INGRESS_GRPC_PORT = "50051" DEFAULT_CHIP_INGRESS_SERVICE_NAME = "chip-ingress" DEFAULT_RED_PANDA_SCHEMA_REGISTRY_PORT = "18081" DEFAULT_RED_PANDA_KAFKA_PORT = "19092" DEFAULT_RED_PANDA_SERVICE_NAME = "redpanda-0" DEFAULT_RED_PANDA_CONSOLE_SERVICE_NAME = "redpanda-console" DEFAULT_RED_PANDA_CONSOLE_PORT = "8080" )
Variables ¶
This section is empty.
Functions ¶
func CreateTopics ¶
func DefaultSubjectNamingStrategy ¶
func DefaultSubjectNamingStrategy(subjectPrefix string, proto protoFile, protoSchemaSet ProtoSchemaSet) (string, error)
func RegisterAndFetchProtos ¶
func RegisterAndFetchProtos(ctx context.Context, client *github.Client, protoSchemaSets []ProtoSchemaSet, schemaRegistryURL string, repoToSubjectNamingStrategy RepositoryToSubjectNamingStrategyFn) error
func ValidateRepoConfiguration ¶
func ValidateRepoConfiguration(repoConfig ProtoSchemaSet) error
Types ¶
type ChipIngressOutput ¶
type Output ¶
type Output struct { ChipIngress *ChipIngressOutput RedPanda *RedPandaOutput }
type ProtoSchemaSet ¶
type ProtoSchemaSet struct { Owner string `toml:"owner"` Repository string `toml:"repository"` Ref string `toml:"ref"` // ref or tag or commit SHA Folders []string `toml:"folders"` // if not provided, all protos will be fetched, otherwise only protos in these folders will be fetched SubjectPrefix string `toml:"subject_prefix"` // optional prefix for subjects }
type RedPandaOutput ¶
type RepositoryToSubjectNamingStrategyFn ¶
type RepositoryToSubjectNamingStrategyFn map[string]SubjectNamingStrategyFn
RepositoryToSubjectNamingStrategyFn is a map of repository names to SubjectNamingStrategyFn functions
type SubjectNamingStrategyFn ¶
type SubjectNamingStrategyFn func(subjectPrefix string, protoFile protoFile, repoConfig ProtoSchemaSet) (string, error)
SubjectNamingStrategyFn is a function that is used to determine the subject name for a given proto file in a given repo
Click to show internal directories.
Click to hide internal directories.