storage

type ContentReader ¶

type ContentReader interface {
	Read(ctx context.Context, cid cid.Cid) ([]byte, error)
}

ContentReader is responsible for fetching content based on it's CID.

type ContentStorage ¶

type ContentStorage interface {
	ContentReader
	ContentWriter
}

ContentStorage allows its user to access content based on CID.

type ContentWriter ¶

type ContentWriter interface {
	Write(ctx context.Context, content []byte, cid cid.Cid) error
}

ContentWriter writes given content with assigned CID

type MessageReader ¶

type MessageReader interface {
	Read(ctx context.Context, cid cid.Cid) (ProtoUnmarshallable, error)
}

MessageReader lets user access message based on CID address

type MessageStorage ¶

type MessageStorage interface {
	MessageReader
	MessageWriter
}

MessageStorage is responsible for accessing the messages based on CID

type MessageWriter ¶

type MessageWriter interface {
	Write(ctx context.Context, message proto.Message) (cid.Cid, error)
}

MessageWriter persists message with CID accessor

type ProtoMessageStorage ¶

type ProtoMessageStorage struct {
	// contains filtered or unexported fields
}

func NewProtoMessageStorage(contentStorage ContentStorage) *ProtoMessageStorage

func (p *ProtoMessageStorage) Read(ctx context.Context, cid cid.Cid) (ProtoUnmarshallable, error)

func (p *ProtoMessageStorage) Write(ctx context.Context, message proto.Message) (cid.Cid, error)

type ProtoUnmarshallable ¶

type ProtoUnmarshallable interface {
	Unmarshall(message proto.Message) error
}

ProtoUnmarshallable can be used to deserialize message data to proto structure