owtp

package

Go to main page

Versions in this module

v2

v2.6.0

Aug 31, 2023

v2.5.0

Feb 8, 2023

v2.4.3

Oct 14, 2022

Changes in this version

+ func JsonUnmarshal(data []byte, v interface{}) error

v2.4.2

Oct 4, 2022

v2.4.1

Sep 26, 2022

v2.4.0

Sep 26, 2022

v2.3.0

May 6, 2021

v2.2.0

May 1, 2021

v2.1.0

Mar 29, 2021

Changes in this version

type OWTPNode

+ func (node *OWTPNode) SetReloadPeerInfoHandler(h func(n *OWTPNode, peerID string) PeerInfo)

v2.0.10

Sep 21, 2020

v2.0.9

Sep 5, 2020

v2.0.8

Sep 4, 2020

Changes in this version

+ func HttpError(w http.ResponseWriter, error string, code int)

v2.0.7

Aug 31, 2020

v2.0.6

Aug 7, 2020

v2.0.5

Jun 3, 2020

v2.0.4

Apr 29, 2020

v2.0.3

Apr 29, 2020

v2.0.2

Mar 5, 2020

v2.0.1

Feb 28, 2020

v2.0.0

Feb 27, 2020

Changes in this version

+ const CurrentDataPacketVersion

+ const DataPacketVersionV1

+ const DefaultTimoutSEC

+ const ErrBadRequest

+ const ErrCustomError

+ const ErrDenialOfService

+ const ErrInternalServerError

+ const ErrKeyAgreementFailed

+ const ErrNetworkDisconnected

+ const ErrNotFoundMethod

+ const ErrReplayAttack

+ const ErrRequestTimeout

+ const ErrResponseMethodDiffer

+ const ErrSecretKeyInvalid

+ const ErrUnauthorized

+ const FinishMethod

+ const HTTP

+ const KeyAgreementMethod

+ const MQ

+ const MaxMessageSize

+ const PingPeriod

+ const PongWait

+ const PrepareMethod

+ const StatusSuccess

+ const WSRequest

+ const WSResponse

+ const Websocket

+ const WriteWait

+ const XForwardedFor

+ const XRealIP

+ var Debug = false

+ func ClientIP(req *http.Request) string

+ func GenerateRangeNum(min, max int) int

+ func HttpListenAddr(addr string, enableSignature bool, handler PeerHandler) (*httpListener, error)

+ func NewOWTPPeerstore() *owtpPeerstore

+ func RandomPrivateKey() string

+ func WSListenAddr(addr string, cert Certificate, enableSignature bool, handler PeerHandler) (*wsListener, error)

+ type Authorization interface

+ DecryptData func(data []byte, key []byte) ([]byte, error)

+ DecryptDataPacket func(data *DataPacket, key []byte) error

+ EnableAuth func() bool

+ EnableKeyAgreement func() bool

+ EncryptData func(data []byte, key []byte) ([]byte, error)

+ EncryptDataPacket func(data *DataPacket, key []byte) error

+ GenerateSignature func(data *DataPacket) bool

+ InitKeyAgreement func(keyAgreement *KeyAgreement) error

+ RequestKeyAgreement func(keyAgreement *KeyAgreement) error

+ ResponseKeyAgreement func(keyAgreement *KeyAgreement) error

+ VerifyKeyAgreement func(keyAgreement *KeyAgreement) bool

+ VerifySignature func(data *DataPacket) bool

+ type AuthorizationBase struct

+ func (base *AuthorizationBase) DecryptData(data []byte, key []byte) ([]byte, error)

+ func (base *AuthorizationBase) DecryptDataPacket(data *DataPacket, key []byte) error

+ func (base *AuthorizationBase) EnableAuth() bool

+ func (base *AuthorizationBase) EnableKeyAgreement() bool

+ func (base *AuthorizationBase) EncryptData(data []byte, key []byte) ([]byte, error)

+ func (base *AuthorizationBase) EncryptDataPacket(data *DataPacket, key []byte) error

+ func (base *AuthorizationBase) GenerateSignature(data *DataPacket) bool

+ func (base *AuthorizationBase) InitKeyAgreement(keyAgreement *KeyAgreement) error

+ func (base *AuthorizationBase) RequestKeyAgreement(keyAgreement *KeyAgreement) error

+ func (base *AuthorizationBase) ResponseKeyAgreement(keyAgreement *KeyAgreement) error

+ func (base *AuthorizationBase) VerifyKeyAgreement(keyAgreement *KeyAgreement) bool

+ func (base *AuthorizationBase) VerifySignature(data *DataPacket) bool

+ type Certificate struct

+ func NewCertificate(privateKey string, consultType ...string) (Certificate, error)

+ func NewRandomCertificate() Certificate

+ func (cert *Certificate) ID() string

+ func (cert *Certificate) KeyPair() (priv string, pub string)

+ func (cert *Certificate) PrivateKeyBytes() []byte

+ func (cert *Certificate) PublicKeyBytes() []byte

+ type ConnectConfig struct

+ Account string

+ Address string

+ ConnectType string

+ EnableKeyAgreement bool

+ EnableSSL bool

+ EnableSignature bool

+ Exchange string

+ Password string

+ ReadBufferSize int

+ ReadQueueName string

+ WriteBufferSize int

+ WriteQueueName string

+ type ConnectType int

+ type Context struct

+ Method string

+ PID string

+ Peer Peer

+ RemoteAddress string

+ Req uint64

+ Resp Response

+ Version int64

+ func NewContext(req, nonce uint64, pid, method string, inputs interface{}) *Context

+ func (ctx *Context) DelSession(name string)

+ func (ctx *Context) DestroySession()

+ func (ctx *Context) GetSession(name string) interface{}

+ func (ctx *Context) Params() gjson.Result

+ func (ctx *Context) Response(result interface{}, status uint64, msg string)

+ func (ctx *Context) ResponseStopRun(result interface{}, status uint64, msg string)

+ func (ctx *Context) SetSession(name string, value interface{})

+ type DataPacket struct

+ Data interface{}

+ Method string

+ Nonce uint64

+ Req uint64

+ SecretData SecretData

+ Signature string

+ Timestamp int64

+ Version int64

+ func NewDataPacket(json gjson.Result) *DataPacket

+ type HTTPClient struct

+ ReadBufferSize int

+ WriteBufferSize int

+ func HTTPDial(pid, url string, handler PeerHandler, header map[string]string, ...) (*HTTPClient, error)

+ func NewHTTPClient(pid string, responseWriter http.ResponseWriter, request *http.Request, ...) (*HTTPClient, error)

+ func NewHTTPClientWithHeader(responseWriter http.ResponseWriter, request *http.Request, hander PeerHandler, ...) (*HTTPClient, error)

+ func (c *HTTPClient) ConnectConfig() ConnectConfig

+ func (c *HTTPClient) EnableKeyAgreement() bool

+ func (c *HTTPClient) HandleRequest() error

+ func (c *HTTPClient) IsConnected() bool

+ func (c *HTTPClient) IsHost() bool

+ func (c *HTTPClient) LocalAddr() net.Addr

+ func (c *HTTPClient) PID() string

+ func (c *HTTPClient) RemoteAddr() net.Addr

+ type HandlerFunc func(ctx *Context)

+ type KeyAgreement struct

+ EncryptType string

+ Key string

+ PrivateKeyInitiator string

+ PrivateKeyResponder string

+ PublicKeyInitiator string

+ PublicKeyResponder string

+ S2 string

+ SA string

+ SB string

+ TmpPrivateKeyInitiator string

+ TmpPrivateKeyResponder string

+ TmpPublicKeyInitiator string

+ TmpPublicKeyResponder string

+ type Listener interface

+ Accept func() (Peer, error)

+ Addr func() net.Addr

+ Close func() error

+ type MQClient struct

+ ReadBufferSize int

+ WriteBufferSize int

+ func MQDial(pid, url string, handler PeerHandler) (*MQClient, error)

+ func NewMQClient(pid string, conn *amqp.Connection, channel *amqp.Channel, hander PeerHandler, ...) (*MQClient, error)

+ func (c *MQClient) ConnectConfig() ConnectConfig

+ func (c *MQClient) EnableKeyAgreement() bool

+ func (c *MQClient) IsConnected() bool

+ func (c *MQClient) IsHost() bool

+ func (c *MQClient) LocalAddr() net.Addr

+ func (c *MQClient) PID() string

+ func (c *MQClient) RemoteAddr() net.Addr

+ type MqAddr struct

+ NetWork string

+ func (m *MqAddr) Network() string

+ func (m *MqAddr) String() string

+ type NodeConfig struct

+ Cert Certificate

+ Peerstore Peerstore

+ TimeoutSEC int

+ type OWTPAuth struct

+ func NewOWTPAuthWithCertificate(cert Certificate, enable bool) (*OWTPAuth, error)

+ func (auth *OWTPAuth) DecryptData(data []byte, key []byte) ([]byte, error)

+ func (auth *OWTPAuth) DecryptDataPacket(packet *DataPacket, key []byte) error

+ func (auth *OWTPAuth) EnableAuth() bool

+ func (auth *OWTPAuth) EnableKeyAgreement() bool

+ func (auth *OWTPAuth) EncryptData(data []byte, key []byte) ([]byte, error)

+ func (auth *OWTPAuth) EncryptDataPacket(packet *DataPacket, key []byte) error

+ func (auth *OWTPAuth) GenerateSignature(data *DataPacket) bool

+ func (auth *OWTPAuth) HTTPAuthHeader() map[string]string

+ func (auth *OWTPAuth) InitKeyAgreement(keyAgreement *KeyAgreement) error

+ func (auth *OWTPAuth) LocalPID() string

+ func (auth *OWTPAuth) RemotePID() string

+ func (auth *OWTPAuth) RequestKeyAgreement(keyAgreement *KeyAgreement) error

+ func (auth *OWTPAuth) ResponseKeyAgreement(keyAgreement *KeyAgreement) error

+ func (auth *OWTPAuth) VerifyKeyAgreement(keyAgreement *KeyAgreement) bool

+ func (auth *OWTPAuth) VerifySignature(data *DataPacket) bool

+ type OWTPNode struct

+ Join chan Peer

+ Leave chan Peer

+ Stop chan struct{}

+ func NewNode(config NodeConfig) *OWTPNode

+ func NewOWTPNode(cert Certificate, readBufferSize, writeBufferSize int) *OWTPNode

+ func RandomOWTPNode(consultType ...string) *OWTPNode

+ func (node *OWTPNode) AddOnlinePeer(peer Peer)

+ func (node *OWTPNode) Call(pid string, method string, params interface{}, sync bool, reqFunc RequestFunc) error

+ func (node *OWTPNode) CallSync(pid string, method string, params interface{}) (*Response, error)

+ func (node *OWTPNode) Certificate() *Certificate

+ func (node *OWTPNode) Close()

+ func (node *OWTPNode) CloseListener(connectType string)

+ func (node *OWTPNode) ClosePeer(pid string)

+ func (node *OWTPNode) Connect(pid string, config ConnectConfig) (Peer, error)

+ func (node *OWTPNode) ConnectAndCall(pid string, config ConnectConfig, method string, params interface{}, sync bool, ...) error

+ func (node *OWTPNode) GetOnlinePeer(id string) Peer

+ func (node *OWTPNode) GetValueForPeer(peer Peer, key string) interface{}

+ func (node *OWTPNode) HandleFinishFunc(handler HandlerFunc)

+ func (node *OWTPNode) HandleFunc(method string, handler HandlerFunc)

+ func (node *OWTPNode) HandlePrepareFunc(handler HandlerFunc)

+ func (node *OWTPNode) IsConnectPeer(pid string) bool

+ func (node *OWTPNode) KeyAgreement(pid string, consultType string) error

+ func (node *OWTPNode) Listen(config ConnectConfig) error

+ func (node *OWTPNode) Listening(connectType string) bool

+ func (node *OWTPNode) NodeID() string

+ func (node *OWTPNode) OnPeerClose(peer Peer, reason string)

+ func (node *OWTPNode) OnPeerNewDataPacketReceived(peer Peer, packet *DataPacket)

+ func (node *OWTPNode) OnPeerOpen(peer Peer)

+ func (node *OWTPNode) OnlinePeers() []Peer

+ func (node *OWTPNode) Peerstore() Peerstore

+ func (node *OWTPNode) PutValueForPeer(peer Peer, key string, val interface{}) error

+ func (node *OWTPNode) RemoveOfflinePeer(id string)

+ func (node *OWTPNode) Run() error

+ func (node *OWTPNode) SetCloseHandler(h func(n *OWTPNode, peer PeerInfo))

+ func (node *OWTPNode) SetOpenHandler(h func(n *OWTPNode, peer PeerInfo))

+ func (node *OWTPNode) SetPeerstore(store Peerstore)

+ type Param struct

+ type Peer interface

+ ConnectConfig func() ConnectConfig

+ EnableKeyAgreement func() bool

+ IsConnected func() bool

+ IsHost func() bool

+ LocalAddr func() net.Addr

+ PID func() string

+ RemoteAddr func() net.Addr

+ type PeerAttribute map[string]interface

+ type PeerHandler interface

+ GetValueForPeer func(peer Peer, key string) interface{}

+ OnPeerClose func(peer Peer, reason string)

+ OnPeerNewDataPacketReceived func(peer Peer, packet *DataPacket)

+ OnPeerOpen func(peer Peer)

+ PutValueForPeer func(peer Peer, key string, val interface{}) error

+ type PeerInfo struct

+ Config ConnectConfig

+ ID string

+ type Peerstore interface

+ Delete func(id string, key string) error

+ Destroy func(id string) error

+ Get func(id string, key string) interface{}

+ GetString func(id string, key string) string

+ PeerInfo func(id string) PeerInfo

+ Put func(id string, key string, val interface{}) error

+ SavePeer func(peer Peer)

+ type RequestFunc func(resp Response)

+ type RequestQueue map[uint64]requestEntry

+ type Response struct

+ Msg string

+ Result interface{}

+ Status uint64

+ func (resp *Response) JsonData() gjson.Result

+ type SecretData struct

+ EncryptType string

+ PublicKeyInitiator string

+ PublicKeyResponder string

+ S2 string

+ SA string

+ SB string

+ TmpPublicKeyInitiator string

+ TmpPublicKeyResponder string

+ type ServeMux struct

+ func NewServeMux(timeoutSEC int) *ServeMux

+ func (mux *ServeMux) AddRequest(peer Peer, nonce uint64, time int64, method string, reqFunc RequestFunc, ...) error

+ func (mux *ServeMux) HandleFunc(method string, handler HandlerFunc)

+ func (mux *ServeMux) RemoveRequest(pid string, nonce uint64) error

+ func (mux *ServeMux) ResetRequestQueue(pid string)

+ func (mux *ServeMux) ServeOWTP(pid string, ctx *Context)

+ type SessionManager struct

+ func NewSessionManager(provideName string, cf *session.ManagerConfig) (*SessionManager, error)

+ func (store *SessionManager) Delete(id string, key string) error

+ func (store *SessionManager) Destroy(id string) error

+ func (store *SessionManager) GC()

+ func (store *SessionManager) Get(id string, key string) interface{}

+ func (store *SessionManager) GetActiveSession() int

+ func (store *SessionManager) GetProvider() session.Provider

+ func (store *SessionManager) GetSessionStore(pid string) (sessions session.Store, err error)

+ func (store *SessionManager) GetString(id string, key string) string

+ func (store *SessionManager) PeerInfo(id string) PeerInfo

+ func (store *SessionManager) Put(id string, key string, val interface{}) error

+ func (store *SessionManager) SavePeer(peer Peer)

+ func (store *SessionManager) SessionDestroy(pid string)

+ type WSClient struct

+ ReadBufferSize int

+ WriteBufferSize int

+ func Dial(pid, url string, handler PeerHandler, header map[string]string, ...) (*WSClient, error)

+ func NewWSClient(pid string, conn *websocket.Conn, handler PeerHandler, auth Authorization, ...) (*WSClient, error)

+ func NewWSClientWithHeader(header http.Header, cert Certificate, conn *websocket.Conn, ...) (*WSClient, error)

+ func (c *WSClient) ConnectConfig() ConnectConfig

+ func (c *WSClient) EnableKeyAgreement() bool

+ func (c *WSClient) IsConnected() bool

+ func (c *WSClient) IsHost() bool

+ func (c *WSClient) LocalAddr() net.Addr

+ func (c *WSClient) PID() string

+ func (c *WSClient) RemoteAddr() net.Addr

Other modules containing this package

github.com/blocktree/openwallet

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL