xirrAsync

Documentation

Index

• type IProcessor
  • func NewProcessor() IProcessor
• type IRequest
  • func NewRequest(id int64, payments []netPresentValue.IPayment) IRequest
• type IResponse
  • func NewResponse(id int64, res numMethods.IResult) IResponse
• type Request
  • func (r *Request) Payments() []netPresentValue.IPayment
  • func (r *Request) RequestId() int64
• type RequestsProcessor
  • func (p *RequestsProcessor) Requests() chan IRequest
  • func (p *RequestsProcessor) Responses() <-chan IResponse
  • func (p *RequestsProcessor) Start(coresCount int)
  • func (p *RequestsProcessor) Stop() <-chan bool
• type Response
  • func (r *Response) RequestId() int64
  • func (r *Response) Result() numMethods.IResult

Types

type IProcessor

type IProcessor interface {
	Requests() chan IRequest

	Responses() <-chan IResponse

	Start(coresCount int)

	Stop() <-chan bool
}

func NewProcessor

func NewProcessor() IProcessor

Factory method

type IRequest

type IRequest interface {
	RequestId() int64

	Payments() []netPresentValue.IPayment
}

func NewRequest

func NewRequest(id int64, payments []netPresentValue.IPayment) IRequest

type IResponse

type IResponse interface {
	RequestId() int64

	Result() numMethods.IResult
}

func NewResponse

func NewResponse(id int64, res numMethods.IResult) IResponse

type Request

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

func (*Request) Payments

func (r *Request) Payments() []netPresentValue.IPayment

func (*Request) RequestId

func (r *Request) RequestId() int64

type RequestsProcessor

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

func (*RequestsProcessor) Requests

func (p *RequestsProcessor) Requests() chan IRequest

func (*RequestsProcessor) Responses

func (p *RequestsProcessor) Responses() <-chan IResponse

func (*RequestsProcessor) Start

func (p *RequestsProcessor) Start(coresCount int)

func (*RequestsProcessor) Stop

func (p *RequestsProcessor) Stop() <-chan bool

type Response

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

func (*Response) RequestId

func (r *Response) RequestId() int64

func (*Response) Result

func (r *Response) Result() numMethods.IResult