pubsub

Documentation

Index

• Constants
• type NatsPublishClient
• type NatsPublishClientImpl
  • func NewNatsPublishClientImpl(logger *zap.SugaredLogger, pubSubClient *PubSubClient) *NatsPublishClientImpl
  • func (impl *NatsPublishClientImpl) Publish(req *PublishRequest) (string, error)
• type PubSubClient
  • func NewPubSubClient(logger *zap.SugaredLogger) (*PubSubClient, error)
• type PubSubConfig
• type PublishRequest

Constants

const (
	CD_SUCCESS          = "ORCHESTRATOR.CD.TRIGGER"
	WEBHOOK_EVENT_TOPIC = "ORCHESTRATOR.WEBHOOK_EVENT"
)

Types

type NatsPublishClient

type NatsPublishClient interface {
	Publish(req *PublishRequest) (string, error)
}

type NatsPublishClientImpl

type NatsPublishClientImpl struct {
	// contains filtered or unexported fields
}

func NewNatsPublishClientImpl

func NewNatsPublishClientImpl(logger *zap.SugaredLogger, pubSubClient *PubSubClient) *NatsPublishClientImpl

func (*NatsPublishClientImpl) Publish

func (impl *NatsPublishClientImpl) Publish(req *PublishRequest) (string, error)

type PubSubClient

type PubSubClient struct {
	Conn        stan.Conn
	AckDuration int
	// contains filtered or unexported fields
}

func NewPubSubClient

func NewPubSubClient(logger *zap.SugaredLogger) (*PubSubClient, error)

#nosec

type PubSubConfig

type PubSubConfig struct {
	NatsServerHost string `env:"NATS_SERVER_HOST" envDefault:"nats://localhost:4222"`
	ClusterId      string `env:"CLUSTER_ID" envDefault:"devtron-stan"`
	ClientId       string `env:"CLIENT_ID" envDefault:"orchestrator"`
	AckDuration    string `env:"ACK_DURATION" envDefault:"30"`
}

type PublishRequest

type PublishRequest struct {
	Topic   string          `json:"topic"`
	Payload json.RawMessage `json:"payload"`
}