transport

Documentation

Index

• func GetTransports(ctx context.Context) []string
• func InitializeTransports()
• func RegisterTransport(transport ITransport)
• func StartTransports()
• func UpdateTransportStatus(ctx context.Context, t ITransport, m msg.Message, status string)
• type ITransport
  • func GetTransport(ctx context.Context, name string) (ITransport, error)
• type TransportConfig

Functions

func GetTransports

func GetTransports(ctx context.Context) []string

func InitializeTransports

func InitializeTransports()

func RegisterTransport

func RegisterTransport(transport ITransport)

func StartTransports

func StartTransports()

func UpdateTransportStatus

func UpdateTransportStatus(ctx context.Context, t ITransport, m msg.Message, status string)

Types

type ITransport

type ITransport interface {
	GetName() string
	Start()
	SendMessage(ctx context.Context, config TransportConfig, message msg.Message) (err error)
	NewTransportConfig(ctx context.Context)
}

func GetTransport

func GetTransport(ctx context.Context, name string) (ITransport, error)

type TransportConfig

type TransportConfig struct {
	gorm.Model `json:"-"`
	UserID     uint `json:"-"`
	Transport  string
	Config     string
}