pubsub_lib

May 13, 2024

Changes in this version

+ const CHART_SCAN_DURABLE

+ const CHART_SCAN_GROUP

+ const CHART_SCAN_TOPIC

Apr 8, 2024

Changes in this version

+ const CD_PIPELINE_DELETE_EVENT_DURABLE

+ const CD_PIPELINE_DELETE_EVENT_GROUP

+ const CD_PIPELINE_DELETE_EVENT_TOPIC

+ const IMAGE_SCANNING_SUCCESS_DURABLE

+ const IMAGE_SCANNING_SUCCESS_GROUP

+ const IMAGE_SCANNING_SUCCESS_TOPIC

+ const NATS_PANIC_MSG_LOG_PREFIX

Feb 19, 2024

Changes in this version

+ const CD_STAGE_SUCCESS_EVENT_DURABLE

+ const CD_STAGE_SUCCESS_EVENT_GROUP

+ const CD_STAGE_SUCCESS_EVENT_TOPIC

Jan 22, 2024

Changes in this version

+ const NATS_MSG_LOG_PREFIX

+ type LoggerFunc func(msg model.PubSubMsg) (logMsg string, keysAndValues []interface{})

type NatsClientConfig

+ NatsMsgAckWaitInSecs int

+ NatsMsgMaxAge int

+ func (ncc NatsClientConfig) GetDefaultNatsConsumerConfig() NatsConsumerConfig

+ func (ncc NatsClientConfig) GetDefaultNatsStreamConfig() NatsStreamConfig

+ func (ncc NatsClientConfig) GetNatsMsgBufferSize() int

type NatsConsumerConfig

+ func (consumerConf NatsConsumerConfig) GetNatsMsgBufferSize() int

type PubSubClientServiceImpl

+ func (impl PubSubClientServiceImpl) Log(loggerFunc LoggerFunc, topic string, subMsg model.PubSubMsg)

+ type ValidateMsg func(msg model.PubSubMsg) bool

Dec 19, 2023

Changes in this version

+ const PANIC_ON_PROCESSING_DURABLE

+ const PANIC_ON_PROCESSING_GROUP

+ const PANIC_ON_PROCESSING_TOPIC

type PubSubClientServiceImpl

+ func (impl PubSubClientServiceImpl) TryCatchCallBack(msg *nats.Msg, callback func(msg *model.PubSubMsg))

Nov 21, 2023

Changes in this version

+ const DEVTRON_CHART_INSTALL_DURABLE

+ const DEVTRON_CHART_INSTALL_GROUP

+ const DEVTRON_CHART_INSTALL_TOPIC

Sep 21, 2023

Changes in this version

+ const HELM_CHART_INSTALL_STATUS_DURABLE

+ const HELM_CHART_INSTALL_STATUS_GROUP

+ const HELM_CHART_INSTALL_STATUS_TOPIC

Jun 21, 2023

Changes in this version

+ const APPLICATION_STATUS_DELETE_DURABLE

+ const APPLICATION_STATUS_DELETE_GROUP

+ const APPLICATION_STATUS_DELETE_TOPIC

+ const APPLICATION_STATUS_UPDATE_DURABLE

+ const APPLICATION_STATUS_UPDATE_GROUP

+ const APPLICATION_STATUS_UPDATE_TOPIC

+ const ARGO_PIPELINE_STATUS_UPDATE_DURABLE

+ const ARGO_PIPELINE_STATUS_UPDATE_GROUP

+ const ARGO_PIPELINE_STATUS_UPDATE_TOPIC

+ const BULK_APPSTORE_DEPLOY_DURABLE

+ const BULK_APPSTORE_DEPLOY_GROUP

+ const BULK_APPSTORE_DEPLOY_TOPIC

+ const BULK_DEPLOY_DURABLE

+ const BULK_DEPLOY_GROUP

+ const BULK_DEPLOY_TOPIC

+ const BULK_HIBERNATE_DURABLE

+ const BULK_HIBERNATE_GROUP

+ const BULK_HIBERNATE_TOPIC

+ const CD_BULK_DEPLOY_TRIGGER_DURABLE

+ const CD_BULK_DEPLOY_TRIGGER_GROUP

+ const CD_BULK_DEPLOY_TRIGGER_TOPIC

+ const CD_COMPLETE_DURABLE

+ const CD_COMPLETE_GROUP

+ const CD_STAGE_COMPLETE_TOPIC

+ const CD_SUCCESS

+ const CD_TRIGGER_DURABLE

+ const CD_TRIGGER_GROUP

+ const CD_WORKFLOW_STATUS_UPDATE

+ const CD_WORKFLOW_STATUS_UPDATE_DURABLE

+ const CD_WORKFLOW_STATUS_UPDATE_GROUP

+ const CI_COMPLETE_DURABLE

+ const CI_COMPLETE_GROUP

+ const CI_COMPLETE_TOPIC

+ const CI_RUNNER_STREAM

+ const CRON_EVENTS

+ const CRON_EVENTS_DURABLE

+ const CRON_EVENTS_GROUP

+ const DEVTRON_TEST_CONSUMER

+ const DEVTRON_TEST_QUEUE

+ const DEVTRON_TEST_STREAM

+ const DEVTRON_TEST_TOPIC

+ const DefaultMaxAge

+ const GIT_SENSOR_STREAM

+ const IMAGE_SCANNER_STREAM

+ const KUBEWATCH_STREAM

+ const NEW_CI_MATERIAL_TOPIC

+ const NEW_CI_MATERIAL_TOPIC_DURABLE

+ const NEW_CI_MATERIAL_TOPIC_GROUP

+ const ORCHESTRATOR_STREAM

+ const TOPIC_CI_SCAN

+ const TOPIC_CI_SCAN_DURABLE

+ const TOPIC_CI_SCAN_GRP

+ const WEBHOOK_EVENT_DURABLE

+ const WEBHOOK_EVENT_GROUP

+ const WEBHOOK_EVENT_TOPIC

+ const WORKFLOW_STATUS_UPDATE_DURABLE

+ const WORKFLOW_STATUS_UPDATE_GROUP

+ const WORKFLOW_STATUS_UPDATE_TOPIC

+ var NatsConsumerWiseConfigMapping = map[string]NatsConsumerConfig

+ var NatsStreamWiseConfigMapping = map[string]NatsStreamConfig

+ func AddStream(js nats.JetStreamContext, streamConfig *nats.StreamConfig, ...) error

+ func GetStreamSubjects(streamName string) []string

+ func ParseAndFillStreamWiseAndConsumerWiseConfigMaps()

+ type ConfigJson struct

+ ConsumerConfigJson string

+ StreamConfigJson string

+ type LogsConfig struct

+ DefaultLogTimeLimit int64

+ type NatsClient struct

+ Conn nats.Conn

+ JetStrCtxt nats.JetStreamContext

+ NatsMsgBufferSize int

+ NatsMsgProcessingBatchSize int

+ func NewNatsClient(logger *zap.SugaredLogger) (*NatsClient, error)

+ type NatsClientConfig struct

+ NatsConsumerConfig string

+ NatsMsgBufferSize int

+ NatsMsgProcessingBatchSize int

+ NatsServerHost string

+ NatsStreamConfig string

+ type NatsConsumerConfig struct

+ AckWaitInSecs int

+ NatsMsgBufferSize int

+ NatsMsgProcessingBatchSize int

+ type NatsStreamConfig struct

+ StreamConfig StreamConfig

+ type NatsTopic struct

+ func GetNatsTopic(topicName string) NatsTopic

+ type PubSubClientService interface

+ Publish func(topic string, msg string) error

+ Subscribe func(topic string, callback func(msg *PubSubMsg)) error

+ type PubSubClientServiceImpl struct

+ Logger *zap.SugaredLogger

+ NatsClient *NatsClient

+ func NewPubSubClientServiceImpl(logger *zap.SugaredLogger) *PubSubClientServiceImpl

+ func (impl PubSubClientServiceImpl) Publish(topic string, msg string) error

+ func (impl PubSubClientServiceImpl) Subscribe(topic string, callback func(msg *PubSubMsg)) error

+ type PubSubMsg struct

+ Data string

+ type StreamConfig struct

+ MaxAge time.Duration