internal

type Callback interface {
	// contains filtered or unexported methods
}

type CallbackChan chan *CallbackResult

type CallbackFn func(error, ilp.Message)

type CallbackResult struct {
	Err error
	Msg ilp.Message
}

type Config struct {
	Env      string `yaml:"env"`
	LogLevel string `yaml:"log_level"`
	DevMode  bool   `yaml:"dev_mode"`
	Admin    struct {
		Enable bool   `yaml:"enable"`
		Host   string `yaml:"string"`
		Port   int    `yaml:"port"`
	} `yaml:"admin"`
	IlpAddress         ilp.Address `yaml:"ilpAddress"`
	StreamSharedSecret string      `yaml:"sharedSecret"`
	BTP                struct {
		Host string `yaml:"host"`
		Port int    `yaml:"port"`
	} `yaml:"btp"`
	Storage storage.Config `yaml:"storage"`
	Peers   []Peer         `yaml:"peers"`
}

type Opts struct {
	Log     *zap.Logger
	Config  *Config
	Route   *Router
	Storage storage.Storer

	Transports []Transport
}

type Peer struct {
	Transport string `yaml:"transport"`
	Host      string `yaml:"host"`
	Port      int    `yaml:"port"`
	Auth      struct {
		User  string `yaml:"user"`
		Token string `yaml:"token"`
	} `yaml:"auth"`
}

type PingRequest struct {
	Address ilp.Address `json:"address"`
}

type PingResponse struct {
	Error    string        `json:"error,omitempty"`
	Address  ilp.Address   `json:"address"`
	Duration time.Duration `json:"duration"`
}

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

type Sender interface {
	SendMessage(context.Context, string, *ilp.MessagePrepare, [32]byte, Callback) error
}

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

type Transport interface {
	// Start starts up the transport and begins accepting connections.
	Start() (<-chan *TransportConnection, error)
	// Open opens a new connection with the remote
	Open(address string) (*TransportConnection, error)
	// Close closes the connection
	Close(id string) error
	// Send sends data over a connection
	Send(id string, data []byte) error
	// Stop starts tearing down the transports. It stops accepting new peer
	// and waits for the completion of pending ones.
	Stop(ctx context.Context) error
	// Name uniquely identifies the transport. Used mainly for logging purposes.
	Name() string
}

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

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