v2

package

Go to main page

Versions in this module

v0

v0.29.4

Sep 1, 2024

v0.29.3

Jul 29, 2024

v0.29.2

Jul 29, 2024

v0.29.1

Jul 17, 2024

v0.29.0

Jul 17, 2024

v0.28.0

Feb 3, 2024

v0.27.0

Mar 22, 2023

Changes in this version

+ var ErrIncorrectProtocol = fmt.Errorf("version 2 protocol requires a ed25519+jwt based security system")

type Request

+ func (r *Request) CallerPublicData() string

+ func (r *Request) SignerPublicData() string

type SecureRequest

+ func (r *SecureRequest) CallerPublicData() string

+ func (r *SecureRequest) SetSigner(signer []byte) error

v0.26.2

Nov 7, 2022

Changes in this version

+ var ErrInvalidJSON = errors.New("supplied JSON document does not pass schema validation")

+ func NewRemoteSignedSecureRequest(request protocol.Request, security inter.SecurityProvider) (secure protocol.SecureRequest, err error)

+ func NewReplyFromSecureReply(sr protocol.SecureReply) (rep protocol.Reply, err error)

+ func NewRequestFromSecureRequest(sr protocol.SecureRequest) (protocol.Request, error)

+ func NewSecureReply(reply protocol.Reply, security inter.SecurityProvider) (secure protocol.SecureReply, err error)

+ func NewSecureReplyFromTransport(message protocol.TransportMessage, security inter.SecurityProvider, ...) (secure protocol.SecureReply, err error)

+ func NewSecureRequest(request protocol.Request, security inter.SecurityProvider) (secure protocol.SecureRequest, err error)

+ func NewSecureRequestFromTransport(message protocol.TransportMessage, security inter.SecurityProvider, ...) (secure protocol.SecureRequest, err error)

+ func NewTransportFromJSON(data []byte) (message protocol.TransportMessage, err error)

+ func NewTransportMessage(certname string) (message protocol.TransportMessage, err error)

+ type FederationTransportHeader struct

+ ReplyTo string

+ RequestID string

+ Targets []string

+ type Reply struct

+ MessageBody []byte

+ Protocol protocol.ProtocolVersion

+ Request string

+ Sender string

+ SendingAgent string

+ TimeStamp int64

+ func (r *Reply) Agent() string

+ func (r *Reply) FederationReplyTo() (replyto string, federated bool)

+ func (r *Reply) FederationRequestID() (id string, federated bool)

+ func (r *Reply) FederationTargets() (targets []string, federated bool)

+ func (r *Reply) IsFederated() bool

+ func (r *Reply) IsValidJSON(data []byte) (err error)

+ func (r *Reply) JSON() ([]byte, error)

+ func (r *Reply) Message() (msg []byte)

+ func (r *Reply) NetworkHops() [][3]string

+ func (r *Reply) RecordNetworkHop(in string, processor string, out string)

+ func (r *Reply) RequestID() string

+ func (r *Reply) SenderID() string

+ func (r *Reply) SetFederationReplyTo(reply string)

+ func (r *Reply) SetFederationRequestID(id string)

+ func (r *Reply) SetFederationTargets(targets []string)

+ func (r *Reply) SetMessage(message []byte)

+ func (r *Reply) SetUnfederated()

+ func (r *Reply) Time() time.Time

+ func (r *Reply) Version() protocol.ProtocolVersion

+ type ReqEnvelope struct

+ Agent string

+ CallerID string

+ Collective string

+ Filter *protocol.Filter

+ RequestID string

+ SenderID string

+ TTL int

+ Time int64

+ type Request struct

+ MessageBody []byte

+ Protocol protocol.ProtocolVersion

+ func (r *Request) Agent() string

+ func (r *Request) CallerID() string

+ func (r *Request) Collective() string

+ func (r *Request) FederationReplyTo() (replyTo string, federated bool)

+ func (r *Request) FederationRequestID() (id string, federated bool)

+ func (r *Request) FederationTargets() (targets []string, federated bool)

+ func (r *Request) Filter() (filter *protocol.Filter, filtered bool)

+ func (r *Request) IsFederated() bool

+ func (r *Request) IsValidJSON(data []byte) error

+ func (r *Request) JSON() ([]byte, error)

+ func (r *Request) Message() []byte

+ func (r *Request) NetworkHops() [][3]string

+ func (r *Request) NewFilter() *protocol.Filter

+ func (r *Request) RecordNetworkHop(in string, processor string, out string)

+ func (r *Request) RequestID() string

+ func (r *Request) SenderID() string

+ func (r *Request) SetAgent(agent string)

+ func (r *Request) SetCallerID(id string)

+ func (r *Request) SetCollective(collective string)

+ func (r *Request) SetFederationReplyTo(reply string)

+ func (r *Request) SetFederationRequestID(id string)

+ func (r *Request) SetFederationTargets(targets []string)

+ func (r *Request) SetFilter(filter *protocol.Filter)

+ func (r *Request) SetMessage(message []byte)

+ func (r *Request) SetRequestID(id string)

+ func (r *Request) SetTTL(ttl int)

+ func (r *Request) SetUnfederated()

+ func (r *Request) TTL() int

+ func (r *Request) Time() time.Time

+ func (r *Request) Version() protocol.ProtocolVersion

+ type SecureReply struct

+ Hash string

+ MessageBody []byte

+ Protocol string

+ SenderJWT string

+ Signature string

+ func (r *SecureReply) IsValidJSON(data []byte) error

+ func (r *SecureReply) JSON() ([]byte, error)

+ func (r *SecureReply) Message() []byte

+ func (r *SecureReply) SetMessage(reply protocol.Reply) error

+ func (r *SecureReply) Valid() bool

+ func (r *SecureReply) Version() string

+ type SecureRequest struct

+ CallerJWT string

+ MessageBody []byte

+ Protocol string

+ Signature string

+ SignerJWT string

+ func (r *SecureRequest) IsValidJSON(data []byte) error

+ func (r *SecureRequest) JSON() ([]byte, error)

+ func (r *SecureRequest) Message() []byte

+ func (r *SecureRequest) SetMessage(request protocol.Request) error

+ func (r *SecureRequest) Valid() bool

+ func (r *SecureRequest) Version() string

+ type TransportHeaders struct

+ Federation *FederationTransportHeader

+ ReplyTo string

+ SeenBy [][3]string

+ Sender string

+ type TransportMessage struct

+ Data []byte

+ Headers *TransportHeaders

+ Protocol protocol.ProtocolVersion

+ func (m *TransportMessage) FederationReplyTo() (string, bool)

+ func (m *TransportMessage) FederationRequestID() (string, bool)

+ func (m *TransportMessage) FederationTargets() ([]string, bool)

+ func (m *TransportMessage) IsFederated() bool

+ func (m *TransportMessage) IsValidJSON(data []byte) error

+ func (m *TransportMessage) JSON() ([]byte, error)

+ func (m *TransportMessage) Message() ([]byte, error)

+ func (m *TransportMessage) NetworkHops() [][3]string

+ func (m *TransportMessage) RecordNetworkHop(in string, processor string, out string)

+ func (m *TransportMessage) ReplyTo() string

+ func (m *TransportMessage) SeenBy() [][3]string

+ func (m *TransportMessage) SenderID() string

+ func (m *TransportMessage) SetFederationReplyTo(reply string)

+ func (m *TransportMessage) SetFederationRequestID(id string)

+ func (m *TransportMessage) SetFederationTargets(targets []string)

+ func (m *TransportMessage) SetReplyData(reply protocol.SecureReply) error

+ func (m *TransportMessage) SetReplyTo(reply string)

+ func (m *TransportMessage) SetRequestData(request protocol.SecureRequest) error

+ func (m *TransportMessage) SetSender(sender string)

+ func (m *TransportMessage) SetUnfederated()

+ func (m *TransportMessage) Version() protocol.ProtocolVersion

v0.26.1

Aug 3, 2022

Changes in this version

+ func NewReply(request protocol.Request, certName string) (protocol.Reply, error)

+ func NewRequest(agent string, sender string, caller string, ttl int, id string, ...) (protocol.Request, error)

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