Documentation ¶
Index ¶
- func MakeIpfsWebService(options IpfsWebServiceOptions) api.DataPeer
- func MakeResidentMemoryDataPeer(options ResidentMemoryStorageOptions) api.DataPeer
- func MakeResidentMemoryPubSubBus() api.PubSubber
- func MakeResidentMemoryStorage(options ResidentMemoryStorageOptions) api.ContentAddressableStorage
- type IpfsWebServiceOptions
- type ResidentMemoryStorageOptions
- type Union
- func (peer Union) Add(r io.Reader) (string, error)
- func (peer Union) Cat(path string) (io.ReadCloser, error)
- func (peer Union) Connect() error
- func (peer Union) Disconnect() error
- func (peer Union) IsUp() bool
- func (peer Union) PubSubPublish(topic, data string) error
- func (peer Union) PubSubSubscribe(topic string) (api.PubSubSubscription, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeIpfsWebService ¶
func MakeIpfsWebService(options IpfsWebServiceOptions) api.DataPeer
func MakeResidentMemoryDataPeer ¶
func MakeResidentMemoryDataPeer(options ResidentMemoryStorageOptions) api.DataPeer
func MakeResidentMemoryStorage ¶
func MakeResidentMemoryStorage(options ResidentMemoryStorageOptions) api.ContentAddressableStorage
Types ¶
type IpfsWebServiceOptions ¶
type Union ¶
type Union struct { Storage api.ContentAddressableStorage Publisher api.PubSubPublisher Subscriber api.PubSubSubscriber Connecter api.ConnectablePeer Disconnecter api.DisconnectablePeer Pinger api.PingablePeer }
func (Union) Disconnect ¶
func (Union) PubSubPublish ¶
func (Union) PubSubSubscribe ¶
func (peer Union) PubSubSubscribe(topic string) (api.PubSubSubscription, error)
Click to show internal directories.
Click to hide internal directories.