manager

Documentation

Index

• Constants
• func GetEnv(envKey string, fallback string) string
• func GetInboxPrefix() string
• func GetStreamName() string
• func GetUser(s string) (string, error)
• type BridgeRole
• type NatsManager
  • func NewNatsManager(args NatsManagerArgs) (*NatsManager, error)
  • func (m *NatsManager) Connect(ctx context.Context)
  • func (m *NatsManager) IsConnected() bool
  • func (m *NatsManager) JetStreamConnect(jetStreamUrl string, logger *zap.SugaredLogger) (*nats.Conn, error)
  • func (m *NatsManager) Start(ctx context.Context) error
  • func (m *NatsManager) Subscribe(ctx context.Context) error
• type NatsManagerArgs
• type Receiver
  • func (r *Receiver) Receive(ctx context.Context, event cloudevents.Event) error
  • func (r *Receiver) Start(ctx context.Context)
• type Sender

Constants

const (
	//  DefaultStreamName is the default name of StreamConfig for JetStream
	DefaultStreamName = "events"

	// MaxPending is the maximum outstanding async publishes that can be inflight at one time.
	MaxPending = 256
)

Functions

func GetEnv

func GetEnv(envKey string, fallback string) string

GetEnv looks up env variable by key and defaults to fallback if env doesn't exists

func GetInboxPrefix

func GetInboxPrefix() string

func GetStreamName

func GetStreamName() string

GetStreamName gets NATS stream name

func GetUser

func GetUser(s string) (string, error)

GetUser gets sub claim from jwt token

Types

type BridgeRole

type BridgeRole string

const (
	BridgeRoleHub  BridgeRole = "hub"
	BridgeRoleEdge BridgeRole = "edge"
)

type NatsManager

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

func NewNatsManager

func NewNatsManager(args NatsManagerArgs) (*NatsManager, error)

func (*NatsManager) Connect

func (m *NatsManager) Connect(ctx context.Context)

func (*NatsManager) IsConnected

func (m *NatsManager) IsConnected() bool

func (*NatsManager) JetStreamConnect

func (m *NatsManager) JetStreamConnect(jetStreamUrl string, logger *zap.SugaredLogger) (*nats.Conn, error)

JetStreamConnect creates a new NATS JetStream connection

func (*NatsManager) Start

func (m *NatsManager) Start(ctx context.Context) error

func (*NatsManager) Subscribe

func (m *NatsManager) Subscribe(ctx context.Context) error

type NatsManagerArgs

type NatsManagerArgs struct {
	Logger *zap.Logger

	NatsURL            string
	Role               BridgeRole
	EdgeMailboxID      string
	EdgeLocationConfig string
	Sink               string
}

type Receiver

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

func (*Receiver) Receive

func (r *Receiver) Receive(ctx context.Context, event cloudevents.Event) error

func (*Receiver) Start

func (r *Receiver) Start(ctx context.Context)

type Sender

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