importer

Documentation

Index

• func GenerateCorrelationId(n int) string
• type Dispatcher
  • func NewDispatcher(ctx context.Context, importer string, stream ImportStream) *Dispatcher
  • func (mng *Dispatcher) Send(req *customerv1.ImportSessionRequest) <-chan *customerv1.ImportSessionResponse
  • func (mng *Dispatcher) Start()
  • func (mng *Dispatcher) Stop()
• type ImportStream
• type Manager
  • func NewManager(ctx context.Context, importer string, stream ImportStream) (*Manager, error)
  • func (mng *Manager) Stop() error
  • func (mng *Manager) UpsertCustomerByRef(interalReference string, customer *customerv1.Customer, ...) error

Functions

func GenerateCorrelationId

func GenerateCorrelationId(n int) string

Types

type Dispatcher

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

func NewDispatcher

func NewDispatcher(ctx context.Context, importer string, stream ImportStream) *Dispatcher

func (*Dispatcher) Send

func (mng *Dispatcher) Send(req *customerv1.ImportSessionRequest) <-chan *customerv1.ImportSessionResponse

func (*Dispatcher) Start

func (mng *Dispatcher) Start()

func (*Dispatcher) Stop

func (mng *Dispatcher) Stop()

type ImportStream

type ImportStream interface {
	Receive() (*customerv1.ImportSessionResponse, error)
	Send(*customerv1.ImportSessionRequest) error
	CloseRequest() error
	CloseResponse() error
}

type Manager

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

func NewManager

func NewManager(ctx context.Context, importer string, stream ImportStream) (*Manager, error)

func (*Manager) Stop

func (mng *Manager) Stop() error

func (*Manager) UpsertCustomerByRef

func (mng *Manager) UpsertCustomerByRef(interalReference string, customer *customerv1.Customer, extra map[string]interface{}) error