Documentation ¶
Index ¶
- type Keri
- func (r *Keri) FindConnection(prefix string) (*klog.Log, error)
- func (r *Keri) Inception() (*event.Message, error)
- func (r *Keri) Interaction(payload event.SealArray) (*event.Message, error)
- func (r *Keri) KEL() *klog.Log
- func (r *Keri) Prefix() string
- func (r *Keri) ProcessEvent(msg *event.Message) error
- func (r *Keri) ProcessEvents(msgs ...*event.Message) ([]*event.Message, error)
- func (r *Keri) ProcessReceipt(vrc *event.Message) error
- func (r *Keri) Replay(pre string, mode ReplayMode, handler ReplayHandler) error
- func (r *Keri) Rotate() (*event.Message, error)
- func (r *Keri) Sign(data []byte) ([]byte, error)
- func (r *Keri) WaitForReceipt(evt *event.Event, timeout time.Duration) (chan *event.Event, chan error)
- type Option
- type Receipts
- type ReplayHandler
- type ReplayMode
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Keri ¶
type Keri struct {
// contains filtered or unexported fields
}
func New ¶
func New(kms *keymanager.KeyManager, db db.DB, opts ...Option) (*Keri, error)
func (*Keri) Interaction ¶
func (*Keri) ProcessEvents ¶
func (*Keri) Replay ¶
func (r *Keri) Replay(pre string, mode ReplayMode, handler ReplayHandler) error
type Receipts ¶
type Receipts struct {
// contains filtered or unexported fields
}
Message thread-safe message register structure.
func (*Receipts) RegisterRcptChan ¶
RegisterMsgEvent on protocol messages. The message events are triggered for incoming messages. Event will not expect any callback on these events unlike Action events.
type ReplayHandler ¶
type ReplayMode ¶
type ReplayMode int
const ( FirstSeenReplay ReplayMode = iota SequenceNumberReplay )
Click to show internal directories.
Click to hide internal directories.