Directories ¶
Path | Synopsis |
---|---|
app
|
|
broker
Package broker implements a broker server.
|
Package broker implements a broker server. |
broker/connector
Package connector provides the connector of the broker.
|
Package connector provides the connector of the broker. |
broker/connector/kafka_connector
Package kafka_connector provides a connector to Kafka
|
Package kafka_connector provides a connector to Kafka |
broker/connector/redis_connector
Package redis_connector implements a connector with redis
|
Package redis_connector implements a connector with redis |
broker/pkg/types
Package types provides the types of the broker.
|
Package types provides the types of the broker. |
broker/server
Package server provides the start and dependency registration of the broker server
|
Package server provides the start and dependency registration of the broker server |
broker/storage
Package storage provides the storage of the broker.
|
Package storage provides the storage of the broker. |
broker/storage/redis_storage
Package redis_storage implements a storage with redis.
|
Package redis_storage implements a storage with redis. |
trigger/domain/cron
Package cron implemented the cron trigger and handler convertor.go implements the conversion between entity and po
|
Package cron implemented the cron trigger and handler convertor.go implements the conversion between entity and po |
trigger/domain/webhook
Package webhook implemented the webhook trigger and handler convertor.go implements the conversion between entity and po
|
Package webhook implemented the webhook trigger and handler convertor.go implements the conversion between entity and po |
trigger/pkg/constants
Package constants provides the constants of the trigger
|
Package constants provides the constants of the trigger |
trigger/repo
Package repo is a package for the repo layer.
|
Package repo is a package for the repo layer. |
trigger/repo/po
Package po is the package of persistent object
|
Package po is the package of persistent object |
trigger/repo/storage/generate
Package main provides the gorm gen code
|
Package main provides the gorm gen code |
trigger/server
Package server provides the start and dependency registration of the trigger server
|
Package server provides the start and dependency registration of the trigger server |
cmd
|
|
broker
Package main provides the main function of pudding broker
|
Package main provides the main function of pudding broker |
trigger
Package main provides the main function of the trigger
|
Package main provides the main function of the trigger |
Package configs provides config management args.go provides some common command line arguments.
|
Package configs provides config management args.go provides some common command line arguments. |
provider
Package provider implements a koanf.Provider that reads commandline parameters as conf maps.
|
Package provider implements a koanf.Provider that reads commandline parameters as conf maps. |
pkg
|
|
clock
Package clock provides a clock interface and a real clock implementation.
|
Package clock provides a clock interface and a real clock implementation. |
cluster
Package cluster provides a cluster manager.
|
Package cluster provides a cluster manager. |
cronexpr
Package cronexpr parses cron time expressions.
|
Package cronexpr parses cron time expressions. |
db/mysql
Package mysql provides a MySQL client.
|
Package mysql provides a MySQL client. |
errno
Package errno implements errors returned by gRPC.
|
Package errno implements errors returned by gRPC. |
grpc/launcher
Package launcher provides a launcher to start gRPC server, health server and grpc gateway server.
|
Package launcher provides a launcher to start gRPC server, health server and grpc gateway server. |
grpc/resolver
Package resolver provides a resolver interface for service discovery.
|
Package resolver provides a resolver interface for service discovery. |
grpc/swagger
Package swagger contains the generated swagger files.
|
Package swagger contains the generated swagger files. |
log
Package log provides the log config.go contains the log config
|
Package log provides the log config.go contains the log config |
log/logger
Package logger defines logging for components in the pudding project.
|
Package logger defines logging for components in the pudding project. |
mq/kafka
Package kafka implements a kafka client.
|
Package kafka implements a kafka client. |
msgpack
Package msgpack provides a msgpack codec for encoding and decoding
|
Package msgpack provides a msgpack codec for encoding and decoding |
otel
Package otel provides OpenTelemetry utilities.
|
Package otel provides OpenTelemetry utilities. |
redis
Package redis implements a Redis client.
|
Package redis implements a Redis client. |
shutdown
Package shutdown provides a graceful shutdown mechanism.
|
Package shutdown provides a graceful shutdown mechanism. |
storage
Package storage provides the Storage interface and implementation.
|
Package storage provides the Storage interface and implementation. |
tls
Package tls support tls management
|
Package tls support tls management |
utils
Package utils provides some common utils.
|
Package utils provides some common utils. |
Package: init_mysql_env.go init mysql env for test
|
Package: init_mysql_env.go init mysql env for test |
test
|
|
mock/api/gen/pudding/broker/v1
Package mock is a GoMock package.
|
Package mock is a GoMock package. |
mock/app/broker
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
mock/app/broker/connector
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
mock/app/broker/storage
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
mock/app/trigger/repo
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
mock/pkg/mq/kafka
Package mock is a generated GoMock package.
|
Package mock is a generated GoMock package. |
mock/utils
Package test_utils provides some constants for testing.
|
Package test_utils provides some constants for testing. |
Click to show internal directories.
Click to hide internal directories.