ingest

Documentation

Index

• type Adaptable
• type NatsIngest
  • func New(name string, work chan Adaptable, fw inter.Framework, logger *logrus.Entry) ([]*NatsIngest, error)
  • func (na *NatsIngest) Connect(ctx context.Context, cm inter.ConnectionManager) error
  • func (na *NatsIngest) Receiver(ctx context.Context, wg *sync.WaitGroup)

Types

type Adaptable

type Adaptable interface {
	Message() []byte
	SenderID() string
	Time() time.Time
	RequestID() string
}

Adaptable matches both protocol.Request and protocol.Reply

type NatsIngest

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

func New

func New(name string, work chan Adaptable, fw inter.Framework, logger *logrus.Entry) ([]*NatsIngest, error)

func (*NatsIngest) Connect

func (na *NatsIngest) Connect(ctx context.Context, cm inter.ConnectionManager) error

func (*NatsIngest) Receiver

func (na *NatsIngest) Receiver(ctx context.Context, wg *sync.WaitGroup)