Documentation ¶
Index ¶
- func NewDB(ctx context.Context, kvss *kvs.KVS, config *config2.Config, name string) (*network, error)
- func NewNetwork(ctx context.Context, kvss *kvs.KVS, eventsPublisher events.Publisher, ...) (*network, error)
- func NewNetworkConfig() *networkConfig
- func NewStaticNetworkConfigProvider(c *networkConfig) *staticNetworkConfigProvider
- type DataTx
- func (d *DataTx) AddMustSignUser(userID string)
- func (d *DataTx) Commit(sync bool) (string, error)
- func (d *DataTx) Delete(db string, key string) error
- func (d *DataTx) Get(db string, key string) ([]byte, error)
- func (d *DataTx) Put(db string, key string, bytes []byte, a driver.AccessControl) error
- func (d *DataTx) SignAndClose() ([]byte, error)
- type IdentityManager
- type LoadedDataTx
- func (l *LoadedDataTx) CoSignAndClose() ([]byte, error)
- func (l *LoadedDataTx) Commit() error
- func (l *LoadedDataTx) ID() string
- func (l *LoadedDataTx) MustSignUsers() []string
- func (l *LoadedDataTx) Reads() map[string][]*driver.DataRead
- func (l *LoadedDataTx) SignedUsers() []string
- func (l *LoadedDataTx) Writes() map[string][]*driver.DataWrite
- type Network
- type Query
- type QueryIterator
- type Session
- type SessionManager
- type Vault
- func (v *Vault) DiscardTx(txID string, message string) error
- func (v *Vault) GetRWSet(id string, results []byte) (driver.RWSet, error)
- func (v *Vault) NewRWSet(txID string) (driver.RWSet, error)
- func (v *Vault) Status(txID string) (driver.ValidationCode, string, error)
- func (v *Vault) Statuses(ids ...string) ([]driver.TxValidationStatus, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewNetwork ¶
func NewNetwork(ctx context.Context, kvss *kvs.KVS, eventsPublisher events.Publisher, eventsSubscriber events.Subscriber, metricsProvider metrics.Provider, tracerProvider trace.TracerProvider, config *config2.Config, name string, drivers []driver2.NamedDriver, networkConfig driver.NetworkConfig, listenerManager driver.ListenerManager) (*network, error)
func NewNetworkConfig ¶ added in v0.4.0
func NewNetworkConfig() *networkConfig
func NewStaticNetworkConfigProvider ¶ added in v0.4.0
func NewStaticNetworkConfigProvider(c *networkConfig) *staticNetworkConfigProvider
Types ¶
type DataTx ¶
type DataTx struct {
// contains filtered or unexported fields
}
func (*DataTx) AddMustSignUser ¶
func (*DataTx) SignAndClose ¶
type IdentityManager ¶
type IdentityManager struct {
// contains filtered or unexported fields
}
func (*IdentityManager) Me ¶
func (i *IdentityManager) Me() string
type LoadedDataTx ¶
type LoadedDataTx struct {
// contains filtered or unexported fields
}
func (*LoadedDataTx) CoSignAndClose ¶
func (l *LoadedDataTx) CoSignAndClose() ([]byte, error)
func (*LoadedDataTx) Commit ¶
func (l *LoadedDataTx) Commit() error
func (*LoadedDataTx) ID ¶
func (l *LoadedDataTx) ID() string
func (*LoadedDataTx) MustSignUsers ¶
func (l *LoadedDataTx) MustSignUsers() []string
func (*LoadedDataTx) SignedUsers ¶
func (l *LoadedDataTx) SignedUsers() []string
type Network ¶
type Network interface { TransactionManager() driver.TransactionManager EnvelopeService() driver.EnvelopeService }
type Query ¶
type Query struct {
// contains filtered or unexported fields
}
func (*Query) GetDataByRange ¶
type QueryIterator ¶
type QueryIterator struct {
// contains filtered or unexported fields
}
type Session ¶
type Session struct {
// contains filtered or unexported fields
}
Session implements a thread-safe session to orion
func (*Session) LoadDataTx ¶
func (s *Session) LoadDataTx(envBoxed interface{}) (driver.LoadedDataTx, error)
type SessionManager ¶
type SessionManager struct {
// contains filtered or unexported fields
}
func (*SessionManager) NewSession ¶
func (s *SessionManager) NewSession(id string) (driver.Session, error)
Click to show internal directories.
Click to hide internal directories.