ingest

Documentation

Index

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

Types

type Adaptable

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

Adaptable matches both protocol.Request and protocol.Reply

type Framework

type Framework interface {
	Configuration() *config.Config
	MiddlewareServers() (servers srvcache.Servers, err error)
	NewRequestFromTransportJSON(payload []byte, skipvalidate bool) (msg protocol.Request, err error)
	NewReplyFromTransportJSON(payload []byte, skipvalidate bool) (msg protocol.Reply, err error)
}

type NatsIngest

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

func New

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

func (*NatsIngest) Connect

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

func (*NatsIngest) Receiver

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