dwn

package

Go to main page

Versions in this module

v0

v0.1.6

Dec 12, 2024

Changes in this version

+ const SortDirectionAsc

+ const SortDirectionDesc

+ type GenericMessage struct

type MessageSort

+ Direction SortDirection

+ Property string

type Pagination

+ Offset int

+ type SQLStore struct

+ func NewSQLStore(config SQLStoreConfig) (*SQLStore, error)

+ func (s *SQLStore) Clear() error

+ func (s *SQLStore) Close() error

+ func (s *SQLStore) Delete(tenant Tenant, messageCid MessageCid) error

+ func (s *SQLStore) Get(tenant Tenant, messageCid MessageCid) (interface{}, error)

+ func (s *SQLStore) Open() error

+ func (s *SQLStore) Put(tenant Tenant, message interface{}, indexes IndexableKeyValues) error

+ func (s *SQLStore) Query(tenant Tenant, filters []Filter, sort MessageSort, pagination Pagination) error

+ type SQLStoreConfig struct

+ DataSourceName string

+ DriverName string

v0.1.4

Oct 22, 2024

Changes in this version

type DwnConfig

+ BlockstoreLocation string

v0.1.3

Oct 3, 2024

v0.1.2

Sep 24, 2024

Changes in this version

+ const DidNotString

+ const DidNotValid

+ func Validate(did string) error

+ type AllowAllTenants struct

+ func (o AllowAllTenants) IsTenant(tenant string) (bool, error)

+ type Authorization interface

+ type AuthorizationDelegatedGrant struct

+ AuthorDelegatedGrant *DelegatedGrant

+ Signature GeneralJws

+ func (m *AuthorizationDelegatedGrant) Author() string

+ type AuthorizationOwner struct

+ AuthorDelegatedGrant *DelegatedGrant

+ OwnerDelegatedGrant *DelegatedGrant

+ OwnerSignature GeneralJws

+ Signature GeneralJws

+ type B bool

+ type Blob []byte

+ type Cache interface

+ Get func(key string) (DidResolutionResult, bool)

+ Set func(key string, value DidResolutionResult)

+ type DID string

+ type DataCid string

+ type DataStore interface

+ Associate func(Tenant, MessageCid, DataCid) (dataCid DataCid, dataSize int64, err error)

+ Clear func() (err error)

+ Close func() error

+ Delete func(Tenant, MessageCid, DataCid) (err error)

+ Get func(Tenant, MessageCid, DataCid) (dataCid DataCid, dataSize int64, dataStream io.Reader, err error)

+ Open func() error

+ Put func(tenant Tenant, messageCid MessageCid, dataCid DataCid, dataStream io.Reader) (resultCid DataCid, dataSize int64, err error)

+ func NewMemoryDatastore() DataStore

+ type DelegatedGrant struct

+ Authorization PlainAuthorization

+ Descriptor DelegatedGrantDescriptor

+ type DelegatedGrantDescriptor struct

+ EncodedData string

+ RecordId string

+ type Descriptor struct

+ DataCid DataCid

+ DataFormat string

+ DataSize int64

+ DateCreated string

+ DatePublished string

+ Interface string

+ MessageTimestamp string

+ Method string

+ ParentId MessageCid

+ Protocol string

+ ProtocolPath string

+ Published bool

+ Recipient DID

+ Schema string

+ Tags map[string]interface{}

+ type Did struct

+ func (d *Did) GetMethodName(did string) (string, error)

+ func (d *Did) GetMethodSpecificId(did string) (string, error)

+ func (d *Did) Validate(did interface{}) error

+ type DidMethodResolver interface

+ Method func() string

+ Resolve func(did string) (DidResolutionResult, error)

+ type DidResolutionResult struct

+ DidDocument interface{}

+ DidResolutionMetadata struct{ ... }

+ func FetchDidDocument(url string) (DidResolutionResult, error)

+ func ParseDidDocument(filePath string) (DidResolutionResult, error)

+ type DidResolver struct

+ func NewDidResolver(resolvers []DidMethodResolver, cache Cache) *DidResolver

+ func NewStaticDidResolver(didjson string) *DidResolver

+ func (r *DidResolver) Resolve(did string) (DidResolutionResult, error)

+ func (r *DidResolver) ResolveFromFile(filePath string) (DidResolutionResult, error)

+ func (r *DidResolver) ResolveFromURL(url string) (DidResolutionResult, error)

+ type Dwn struct

+ func NewDwn(config DwnConfig) (*Dwn, error)

+ func (d *Dwn) Close() error

+ func (d *Dwn) Open() error

+ func (d *Dwn) ProcessMessage(tenant string, rawMessage map[string]interface{}, dataStream io.Reader) (UnionMessageReply, error)

+ type DwnConfig struct

+ DataStore DataStore

+ DidResolver *DidResolver

+ EventLog EventLog

+ MessageStore MessageStore

+ TenantGate TenantGate

+ type DwnError struct

+ Code string

+ Message string

+ func (e *DwnError) Error() string

+ type EqualFilter struct

+ EqualTo IndexableValue

+ type Event struct

+ type EventLog interface

+ Append func(Tenant, MessageCid, IndexableKeyValues) (err error)

+ Clear func() error

+ Close func() error

+ DeleteEventsByCid func(Tenant, []MessageCid) error

+ GetEvents func(Tenant) ([]string, error)

+ Open func() error

+ QueryEvents func(Tenant, []Filter, EventLogCursor) ([]string, error)

+ func NewMemoryEventLog() EventLog

+ type EventLogCursor string

+ type F float64

+ type Filter interface

+ Property func() string

+ Value func() FilterValue

+ type FilterValue interface

+ type GT struct

+ GT RangeValue

+ type GTE struct

+ GTE RangeValue

+ type GeneralJws struct

+ Payload string

+ Signatures []Signature

+ type HandlerRequest struct

+ DataStream io.Reader

+ Message map[string]interface{}

+ Tenant string

+ type I int64

+ type IndexableKeyValues map[string]IndexableValue

+ type IndexableValue interface

+ type LT struct

+ LT RangeValue

+ type LTE struct

+ LTE RangeValue

+ type MemoryCache struct

+ func NewMemoryCache(expiry time.Duration) *MemoryCache

+ func (c *MemoryCache) Get(key string) (DidResolutionResult, bool)

+ func (c *MemoryCache) Set(key string, value DidResolutionResult)

+ type MemoryDatastore struct

+ func (*MemoryDatastore) Close() error

+ func (*MemoryDatastore) Open() error

+ func (m *MemoryDatastore) Associate(Tenant, MessageCid, DataCid) (dataCid DataCid, dataSize int64, err error)

+ func (m *MemoryDatastore) Clear() (err error)

+ func (m *MemoryDatastore) Delete(Tenant, MessageCid, DataCid) (err error)

+ func (m *MemoryDatastore) Get(Tenant, MessageCid, DataCid) (dataCid DataCid, dataSize int64, dataStream io.Reader, err error)

+ func (m *MemoryDatastore) Put(tenant Tenant, messageCid MessageCid, dataCid DataCid, dataStream io.Reader) (resultCid DataCid, dataSize int64, err error)

+ type MemoryEventLog struct

+ func (*MemoryEventLog) Append(Tenant, MessageCid, IndexableKeyValues) (err error)

+ func (*MemoryEventLog) Close() error

+ func (*MemoryEventLog) DeleteEventsByCid(Tenant, []MessageCid) error

+ func (*MemoryEventLog) GetEvents(Tenant) ([]string, error)

+ func (*MemoryEventLog) Open() error

+ func (*MemoryEventLog) QueryEvents(Tenant, []Filter, EventLogCursor) ([]string, error)

+ func (l *MemoryEventLog) Clear() error

+ type MemoryMessageStore struct

+ func (*MemoryMessageStore) Close() error

+ func (*MemoryMessageStore) Delete(Tenant, MessageCid) (err error)

+ func (*MemoryMessageStore) Get(Tenant, MessageCid) (msg interface{}, err error)

+ func (*MemoryMessageStore) Open() error

+ func (*MemoryMessageStore) Put(Tenant, interface{}, IndexableKeyValues) (err error)

+ func (*MemoryMessageStore) Query(tenant Tenant, filters []Filter, sort MessageSort, pagination Pagination) (err error)

+ func (m *MemoryMessageStore) Clear() (err error)

+ type Message struct

+ type MessageCid string

+ type MessageHandler interface

+ Handle func(dwn *Dwn) error

+ type MessageSort struct

+ DateCreated SortDirection

+ DatePublished SortDirection

+ MessageTimestamp SortDirection

+ type MessageStore interface

+ Clear func() (err error)

+ Close func() error

+ Delete func(Tenant, MessageCid) (err error)

+ Get func(Tenant, MessageCid) (msg interface{}, err error)

+ Open func() error

+ Put func(Tenant, interface{}, IndexableKeyValues) (err error)

+ Query func(tenant Tenant, filters []Filter, sort MessageSort, pagination Pagination) (err error)

+ func NewMemoryMessageStore() MessageStore

+ type MessagesGet struct

+ Authorization PlainAuthorization

+ Descriptor struct{ ... }

+ func (message *MessagesGet) Handle(tenant Tenant, dwn *Dwn) error

+ type MethodHandler interface

+ Handle func(request *HandlerRequest) (UnionMessageReply, error)

+ type OneOfFilter struct

+ OneOf []EqualFilter

+ type Pagination struct

+ Cursor string

+ Limit int

+ type PermissionsGrant struct

+ type PlainAuthorization struct

+ Signature GeneralJws

+ func (m *PlainAuthorization) Author() string

+ type RangeFilter interface

+ RangeValue func() RangeValue

+ type RangeValue interface

+ type RawDwnMessage map[string]interface

+ type RecordsRead struct

+ Authorization AuthorizationDelegatedGrant

+ Descriptor struct{ ... }

+ type RecordsWrite struct

+ Attestation GeneralJws

+ Authorization AuthorizationOwner

+ ContextId string

+ Descriptor Descriptor

+ Encryption struct{ ... }

+ RecordId string

+ func (message *RecordsWrite) Handle(dwn *Dwn) error

+ type S string

+ type ServiceEndpoint struct

+ EncryptionKeys []string

+ Nodes []string

+ SigningKeys []string

+ type Signature struct

+ Protected string

+ Signature string

+ type SortDirection int

+ const Ascending

+ const Descending

+ type StaticDidResolver struct

+ func (o StaticDidResolver) Method() string

+ func (o StaticDidResolver) Resolve(did string) (DidResolutionResult, error)

+ type Status struct

+ Code int

+ Detail string

+ type StoredMessage struct

+ Authorization map[string]interface{}

+ Descriptor map[string]interface{}

+ type Tenant string

+ type TenantGate interface

+ IsTenant func(tenant string) (bool, error)

+ func NewAllowAllTenantGate() TenantGate

+ type UnionMessageReply struct

+ Status Status

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