basinprovider

package
v0.0.5-beta-1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2023 License: MIT, Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const Publications_Callback_TypeID = 0xb4928ae23403b190

Publications_Callback_TypeID is the unique identifier for the type Publications_Callback.

View Source 
const Publications_Callback_done_Params_TypeID = 0x90be9e0983809cf5

Publications_Callback_done_Params_TypeID is the unique identifier for the type Publications_Callback_done_Params.

View Source 
const Publications_Callback_done_Results_TypeID = 0xcd754537fa2ac00e

Publications_Callback_done_Results_TypeID is the unique identifier for the type Publications_Callback_done_Results.

View Source 
const Publications_Callback_write_Params_TypeID = 0x8c6625092276093d

Publications_Callback_write_Params_TypeID is the unique identifier for the type Publications_Callback_write_Params.

View Source 
const Publications_Callback_write_Results_TypeID = 0xc7b7a97070ce93e5

Publications_Callback_write_Results_TypeID is the unique identifier for the type Publications_Callback_write_Results.

View Source 
const Publications_TypeID = 0xfddc20d968f417dd

Publications_TypeID is the unique identifier for the type Publications.

View Source 
const Publications_create_Params_TypeID = 0x8986414763ed9fe4

Publications_create_Params_TypeID is the unique identifier for the type Publications_create_Params.

View Source 
const Publications_create_Results_TypeID = 0x9d09768207bbb14b

Publications_create_Results_TypeID is the unique identifier for the type Publications_create_Results.

View Source 
const Publications_deals_Params_TypeID = 0x889bad5ee80bd4ae

Publications_deals_Params_TypeID is the unique identifier for the type Publications_deals_Params.

View Source 
const Publications_deals_Results_TypeID = 0x8b0e78e7cb3c1c68

Publications_deals_Results_TypeID is the unique identifier for the type Publications_deals_Results.

View Source 
const Publications_latestDeals_Params_TypeID = 0x90b6622e0669b417

Publications_latestDeals_Params_TypeID is the unique identifier for the type Publications_latestDeals_Params.

View Source 
const Publications_latestDeals_Results_TypeID = 0xe7da36d32d5316b8

Publications_latestDeals_Results_TypeID is the unique identifier for the type Publications_latestDeals_Results.

View Source 
const Publications_list_Params_TypeID = 0xa202984178fc6068

Publications_list_Params_TypeID is the unique identifier for the type Publications_list_Params.

View Source 
const Publications_list_Results_TypeID = 0xec1df2a9965771fc

Publications_list_Results_TypeID is the unique identifier for the type Publications_list_Results.

View Source 
const Publications_push_Params_TypeID = 0x85cf10ba0781d1d9

Publications_push_Params_TypeID is the unique identifier for the type Publications_push_Params.

View Source 
const Publications_push_Results_TypeID = 0xdf7b33d89ff629bd

Publications_push_Results_TypeID is the unique identifier for the type Publications_push_Results.

View Source 
const Publications_upload_Params_TypeID = 0xd067b888abba0bca

Publications_upload_Params_TypeID is the unique identifier for the type Publications_upload_Params.

View Source 
const Publications_upload_Results_TypeID = 0xd422be623bb0f731

Publications_upload_Results_TypeID is the unique identifier for the type Publications_upload_Results.

Variables

This section is empty.

Functions

func Publications_Callback_Methods 

func Publications_Callback_Methods(methods []server.Method, s Publications_Callback_Server) []server.Method

Publications_Callback_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Publications_Callback_NewServer 

func Publications_Callback_NewServer(s Publications_Callback_Server) *server.Server

Publications_Callback_NewServer creates a new Server from an implementation of Publications_Callback_Server.

func Publications_Methods 

func Publications_Methods(methods []server.Method, s Publications_Server) []server.Method

Publications_Methods appends Methods to a slice that invoke the methods on s. This can be used to create a more complicated Server.

func Publications_NewServer 

func Publications_NewServer(s Publications_Server) *server.Server

Publications_NewServer creates a new Server from an implementation of Publications_Server.

func RegisterSchema 

func RegisterSchema(reg *schemas.Registry)

Types

type BasinProvider 

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

BasinProvider implements the app.BasinProvider interface.

func New 

func New(ctx context.Context, provider string, secure bool) (*BasinProvider, error)

New creates a new BasinProvider.

func (*BasinProvider) Close 

func (bp *BasinProvider) Close()

Close the connection with the Basin Provider.

func (*BasinProvider) Create 

func (bp *BasinProvider) Create(
	ctx context.Context, ns string, rel string, schema basincapnp.Schema, owner common.Address, cacheDuration int64,
) (bool, error)

Create creates a publication on Basin Provider.

func (*BasinProvider) Deals 

func (bp *BasinProvider) Deals(
	ctx context.Context, ns string, rel string, limit uint32, offset uint64, before app.Timestamp, after app.Timestamp,
) ([]app.DealInfo, error)

Deals lists deals from a given publication.

func (*BasinProvider) LatestDeals 

func (bp *BasinProvider) LatestDeals(
	ctx context.Context, ns string, rel string, n uint32, before app.Timestamp, after app.Timestamp,
) ([]app.DealInfo, error)

LatestDeals lists latest deals from a given publication.

func (*BasinProvider) List 

func (bp *BasinProvider) List(ctx context.Context, owner common.Address) ([]string, error)

List lists all publications from a given address.

func (*BasinProvider) Reconnect 

func (bp *BasinProvider) Reconnect() error

Reconnect with the Basin Provider.

func (*BasinProvider) Upload 

func (bp *BasinProvider) Upload(
	ctx context.Context,
	ns string,
	rel string,
	size uint64,
	r io.Reader,
	signer *app.Signer,
	progress io.Writer,
	timestamp app.Timestamp,
) error

Upload uploads a file to th server.

type BasinServerMock 

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

BasinServerMock is a mocked version of a server implementation using for testing.

func NewBasinServerMock 

func NewBasinServerMock() *BasinServerMock

NewBasinServerMock creates new *BasinServerMock.

func (*BasinServerMock) Create 

func (s *BasinServerMock) Create(_ context.Context, call Publications_create) error

Create handles the Create request.

func (*BasinServerMock) Deals 

func (s *BasinServerMock) Deals(_ context.Context, call Publications_deals) error

Deals lists deals from a given publication.

func (*BasinServerMock) LatestDeals 

func (s *BasinServerMock) LatestDeals(_ context.Context, call Publications_latestDeals) error

LatestDeals lists latest deals from a given publication.

func (*BasinServerMock) List 

func (s *BasinServerMock) List(_ context.Context, call Publications_list) error

List lists all publications from a given address.

func (*BasinServerMock) Push 

func (s *BasinServerMock) Push(_ context.Context, call Publications_push) error

Push handles the Push request.

func (*BasinServerMock) Upload 

func (s *BasinServerMock) Upload(_ context.Context, call Publications_upload) error

Upload handles the Write request.

type Publications 

type Publications capnp.Client

func Publications_ServerToClient 

func Publications_ServerToClient(s Publications_Server) Publications

Publications_ServerToClient creates a new Client from an implementation of Publications_Server. The caller is responsible for calling Release on the returned Client.

func (Publications) AddRef 

func (c Publications) AddRef() Publications

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Publications) Create 

func (c Publications) Create(ctx context.Context, params func(Publications_create_Params) error) (Publications_create_Results_Future, capnp.ReleaseFunc)

func (Publications) Deals 

func (c Publications) Deals(ctx context.Context, params func(Publications_deals_Params) error) (Publications_deals_Results_Future, capnp.ReleaseFunc)

func (Publications) DecodeFromPtr 

func (Publications) DecodeFromPtr(p capnp.Ptr) Publications

func (Publications) EncodeAsPtr 

func (c Publications) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications) GetFlowLimiter 

func (c Publications) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Publications) IsSame 

func (c Publications) IsSame(other Publications) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Publications) IsValid 

func (c Publications) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Publications) LatestDeals 

func (c Publications) LatestDeals(ctx context.Context, params func(Publications_latestDeals_Params) error) (Publications_latestDeals_Results_Future, capnp.ReleaseFunc)

func (Publications) List 

func (c Publications) List(ctx context.Context, params func(Publications_list_Params) error) (Publications_list_Results_Future, capnp.ReleaseFunc)

func (Publications) Push 

func (c Publications) Push(ctx context.Context, params func(Publications_push_Params) error) (Publications_push_Results_Future, capnp.ReleaseFunc)

func (Publications) Release 

func (c Publications) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Publications) Resolve 

func (c Publications) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Publications) SetFlowLimiter 

func (c Publications) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Publications) String 

func (c Publications) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Publications) Upload 

func (c Publications) Upload(ctx context.Context, params func(Publications_upload_Params) error) (Publications_upload_Results_Future, capnp.ReleaseFunc)

func (Publications) WaitStreaming 

func (c Publications) WaitStreaming() error

type Publications_Callback 

type Publications_Callback capnp.Client

func Publications_Callback_ServerToClient 

func Publications_Callback_ServerToClient(s Publications_Callback_Server) Publications_Callback

Publications_Callback_ServerToClient creates a new Client from an implementation of Publications_Callback_Server. The caller is responsible for calling Release on the returned Client.

func (Publications_Callback) AddRef 

func (c Publications_Callback) AddRef() Publications_Callback

AddRef creates a new Client that refers to the same capability as c. If c is nil or has resolved to null, then AddRef returns nil.

func (Publications_Callback) DecodeFromPtr 

func (Publications_Callback) DecodeFromPtr(p capnp.Ptr) Publications_Callback

func (Publications_Callback) Done 

func (c Publications_Callback) Done(ctx context.Context, params func(Publications_Callback_done_Params) error) (Publications_Callback_done_Results_Future, capnp.ReleaseFunc)

func (Publications_Callback) EncodeAsPtr 

func (c Publications_Callback) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_Callback) GetFlowLimiter 

func (c Publications_Callback) GetFlowLimiter() fc.FlowLimiter

Get the current flowcontrol.FlowLimiter used to manage flow control for this client.

func (Publications_Callback) IsSame 

func (c Publications_Callback) IsSame(other Publications_Callback) bool

IsSame reports whether c and other refer to a capability created by the same call to NewClient. This can return false negatives if c or other are not fully resolved: use Resolve if this is an issue. If either c or other are released, then IsSame panics.

func (Publications_Callback) IsValid 

func (c Publications_Callback) IsValid() bool

IsValid reports whether c is a valid reference to a capability. A reference is invalid if it is nil, has resolved to null, or has been released.

func (Publications_Callback) Release 

func (c Publications_Callback) Release()

Release releases a capability reference. If this is the last reference to the capability, then the underlying resources associated with the capability will be released.

Release will panic if c has already been released, but not if c is nil or resolved to null.

func (Publications_Callback) Resolve 

func (c Publications_Callback) Resolve(ctx context.Context) error

Resolve blocks until the capability is fully resolved or the Context expires.

func (Publications_Callback) SetFlowLimiter 

func (c Publications_Callback) SetFlowLimiter(lim fc.FlowLimiter)

Update the flowcontrol.FlowLimiter used to manage flow control for this client. This affects all future calls, but not calls already waiting to send. Passing nil sets the value to flowcontrol.NopLimiter, which is also the default.

func (Publications_Callback) String 

func (c Publications_Callback) String() string

String returns a string that identifies this capability for debugging purposes. Its format should not be depended on: in particular, it should not be used to compare clients. Use IsSame to compare clients for equality.

func (Publications_Callback) WaitStreaming 

func (c Publications_Callback) WaitStreaming() error

func (Publications_Callback) Write 

func (c Publications_Callback) Write(ctx context.Context, params func(Publications_Callback_write_Params) error) (Publications_Callback_write_Results_Future, capnp.ReleaseFunc)

type Publications_Callback_List 

type Publications_Callback_List = capnp.CapList[Publications_Callback]

Publications_Callback_List is a list of Publications_Callback.

func NewPublications_Callback_List 

func NewPublications_Callback_List(s *capnp.Segment, sz int32) (Publications_Callback_List, error)

NewPublications_Callback creates a new list of Publications_Callback.

type Publications_Callback_Server 

type Publications_Callback_Server interface {
	Write(context.Context, Publications_Callback_write) error

	Done(context.Context, Publications_Callback_done) error
}

A Publications_Callback_Server is a Publications_Callback with a local implementation.

type Publications_Callback_done 

type Publications_Callback_done struct {
	*server.Call
}

Publications_Callback_done holds the state for a server call to Publications_Callback.done. See server.Call for documentation.

func (Publications_Callback_done) AllocResults 

func (c Publications_Callback_done) AllocResults() (Publications_Callback_done_Results, error)

AllocResults allocates the results struct.

func (Publications_Callback_done) Args 

func (c Publications_Callback_done) Args() Publications_Callback_done_Params

Args returns the call's arguments.

type Publications_Callback_done_Params 

type Publications_Callback_done_Params capnp.Struct

func NewPublications_Callback_done_Params 

func NewPublications_Callback_done_Params(s *capnp.Segment) (Publications_Callback_done_Params, error)

func NewRootPublications_Callback_done_Params 

func NewRootPublications_Callback_done_Params(s *capnp.Segment) (Publications_Callback_done_Params, error)

func ReadRootPublications_Callback_done_Params 

func ReadRootPublications_Callback_done_Params(msg *capnp.Message) (Publications_Callback_done_Params, error)

func (Publications_Callback_done_Params) DecodeFromPtr 

func (Publications_Callback_done_Params) DecodeFromPtr(p capnp.Ptr) Publications_Callback_done_Params

func (Publications_Callback_done_Params) EncodeAsPtr 

func (s Publications_Callback_done_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_Callback_done_Params) HasSig 

func (s Publications_Callback_done_Params) HasSig() bool

func (Publications_Callback_done_Params) IsValid 

func (s Publications_Callback_done_Params) IsValid() bool

func (Publications_Callback_done_Params) Message 

func (s Publications_Callback_done_Params) Message() *capnp.Message

func (Publications_Callback_done_Params) Segment 

func (s Publications_Callback_done_Params) Segment() *capnp.Segment

func (Publications_Callback_done_Params) SetSig 

func (s Publications_Callback_done_Params) SetSig(v []byte) error

func (Publications_Callback_done_Params) Sig 

func (s Publications_Callback_done_Params) Sig() ([]byte, error)

func (Publications_Callback_done_Params) String 

func (s Publications_Callback_done_Params) String() string

func (Publications_Callback_done_Params) ToPtr 

func (s Publications_Callback_done_Params) ToPtr() capnp.Ptr

type Publications_Callback_done_Params_Future 

type Publications_Callback_done_Params_Future struct{ *capnp.Future }

Publications_Callback_done_Params_Future is a wrapper for a Publications_Callback_done_Params promised by a client call.

func (Publications_Callback_done_Params_Future) Struct 

func (f Publications_Callback_done_Params_Future) Struct() (Publications_Callback_done_Params, error)

type Publications_Callback_done_Params_List 

type Publications_Callback_done_Params_List = capnp.StructList[Publications_Callback_done_Params]

Publications_Callback_done_Params_List is a list of Publications_Callback_done_Params.

func NewPublications_Callback_done_Params_List 

func NewPublications_Callback_done_Params_List(s *capnp.Segment, sz int32) (Publications_Callback_done_Params_List, error)

NewPublications_Callback_done_Params creates a new list of Publications_Callback_done_Params.

type Publications_Callback_done_Results 

type Publications_Callback_done_Results capnp.Struct

func NewPublications_Callback_done_Results 

func NewPublications_Callback_done_Results(s *capnp.Segment) (Publications_Callback_done_Results, error)

func NewRootPublications_Callback_done_Results 

func NewRootPublications_Callback_done_Results(s *capnp.Segment) (Publications_Callback_done_Results, error)

func ReadRootPublications_Callback_done_Results 

func ReadRootPublications_Callback_done_Results(msg *capnp.Message) (Publications_Callback_done_Results, error)

func (Publications_Callback_done_Results) DecodeFromPtr 

func (Publications_Callback_done_Results) DecodeFromPtr(p capnp.Ptr) Publications_Callback_done_Results

func (Publications_Callback_done_Results) EncodeAsPtr 

func (s Publications_Callback_done_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_Callback_done_Results) IsValid 

func (s Publications_Callback_done_Results) IsValid() bool

func (Publications_Callback_done_Results) Message 

func (s Publications_Callback_done_Results) Message() *capnp.Message

func (Publications_Callback_done_Results) Segment 

func (s Publications_Callback_done_Results) Segment() *capnp.Segment

func (Publications_Callback_done_Results) String 

func (s Publications_Callback_done_Results) String() string

func (Publications_Callback_done_Results) ToPtr 

func (s Publications_Callback_done_Results) ToPtr() capnp.Ptr

type Publications_Callback_done_Results_Future 

type Publications_Callback_done_Results_Future struct{ *capnp.Future }

Publications_Callback_done_Results_Future is a wrapper for a Publications_Callback_done_Results promised by a client call.

func (Publications_Callback_done_Results_Future) Struct 

func (f Publications_Callback_done_Results_Future) Struct() (Publications_Callback_done_Results, error)

type Publications_Callback_done_Results_List 

type Publications_Callback_done_Results_List = capnp.StructList[Publications_Callback_done_Results]

Publications_Callback_done_Results_List is a list of Publications_Callback_done_Results.

func NewPublications_Callback_done_Results_List 

func NewPublications_Callback_done_Results_List(s *capnp.Segment, sz int32) (Publications_Callback_done_Results_List, error)

NewPublications_Callback_done_Results creates a new list of Publications_Callback_done_Results.

type Publications_Callback_write 

type Publications_Callback_write struct {
	*server.Call
}

Publications_Callback_write holds the state for a server call to Publications_Callback.write. See server.Call for documentation.

func (Publications_Callback_write) AllocResults 

func (c Publications_Callback_write) AllocResults() (Publications_Callback_write_Results, error)

AllocResults allocates the results struct.

func (Publications_Callback_write) Args 

func (c Publications_Callback_write) Args() Publications_Callback_write_Params

Args returns the call's arguments.

type Publications_Callback_write_Params 

type Publications_Callback_write_Params capnp.Struct

func NewPublications_Callback_write_Params 

func NewPublications_Callback_write_Params(s *capnp.Segment) (Publications_Callback_write_Params, error)

func NewRootPublications_Callback_write_Params 

func NewRootPublications_Callback_write_Params(s *capnp.Segment) (Publications_Callback_write_Params, error)

func ReadRootPublications_Callback_write_Params 

func ReadRootPublications_Callback_write_Params(msg *capnp.Message) (Publications_Callback_write_Params, error)

func (Publications_Callback_write_Params) Chunk 

func (s Publications_Callback_write_Params) Chunk() ([]byte, error)

func (Publications_Callback_write_Params) DecodeFromPtr 

func (Publications_Callback_write_Params) DecodeFromPtr(p capnp.Ptr) Publications_Callback_write_Params

func (Publications_Callback_write_Params) EncodeAsPtr 

func (s Publications_Callback_write_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_Callback_write_Params) HasChunk 

func (s Publications_Callback_write_Params) HasChunk() bool

func (Publications_Callback_write_Params) IsValid 

func (s Publications_Callback_write_Params) IsValid() bool

func (Publications_Callback_write_Params) Message 

func (s Publications_Callback_write_Params) Message() *capnp.Message

func (Publications_Callback_write_Params) Segment 

func (s Publications_Callback_write_Params) Segment() *capnp.Segment

func (Publications_Callback_write_Params) SetChunk 

func (s Publications_Callback_write_Params) SetChunk(v []byte) error

func (Publications_Callback_write_Params) String 

func (s Publications_Callback_write_Params) String() string

func (Publications_Callback_write_Params) ToPtr 

func (s Publications_Callback_write_Params) ToPtr() capnp.Ptr

type Publications_Callback_write_Params_Future 

type Publications_Callback_write_Params_Future struct{ *capnp.Future }

Publications_Callback_write_Params_Future is a wrapper for a Publications_Callback_write_Params promised by a client call.

func (Publications_Callback_write_Params_Future) Struct 

func (f Publications_Callback_write_Params_Future) Struct() (Publications_Callback_write_Params, error)

type Publications_Callback_write_Params_List 

type Publications_Callback_write_Params_List = capnp.StructList[Publications_Callback_write_Params]

Publications_Callback_write_Params_List is a list of Publications_Callback_write_Params.

func NewPublications_Callback_write_Params_List 

func NewPublications_Callback_write_Params_List(s *capnp.Segment, sz int32) (Publications_Callback_write_Params_List, error)

NewPublications_Callback_write_Params creates a new list of Publications_Callback_write_Params.

type Publications_Callback_write_Results 

type Publications_Callback_write_Results capnp.Struct

func NewPublications_Callback_write_Results 

func NewPublications_Callback_write_Results(s *capnp.Segment) (Publications_Callback_write_Results, error)

func NewRootPublications_Callback_write_Results 

func NewRootPublications_Callback_write_Results(s *capnp.Segment) (Publications_Callback_write_Results, error)

func ReadRootPublications_Callback_write_Results 

func ReadRootPublications_Callback_write_Results(msg *capnp.Message) (Publications_Callback_write_Results, error)

func (Publications_Callback_write_Results) DecodeFromPtr 

func (Publications_Callback_write_Results) DecodeFromPtr(p capnp.Ptr) Publications_Callback_write_Results

func (Publications_Callback_write_Results) EncodeAsPtr 

func (s Publications_Callback_write_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_Callback_write_Results) IsValid 

func (s Publications_Callback_write_Results) IsValid() bool

func (Publications_Callback_write_Results) Message 

func (s Publications_Callback_write_Results) Message() *capnp.Message

func (Publications_Callback_write_Results) Segment 

func (s Publications_Callback_write_Results) Segment() *capnp.Segment

func (Publications_Callback_write_Results) String 

func (s Publications_Callback_write_Results) String() string

func (Publications_Callback_write_Results) ToPtr 

func (s Publications_Callback_write_Results) ToPtr() capnp.Ptr

type Publications_Callback_write_Results_Future 

type Publications_Callback_write_Results_Future struct{ *capnp.Future }

Publications_Callback_write_Results_Future is a wrapper for a Publications_Callback_write_Results promised by a client call.

func (Publications_Callback_write_Results_Future) Struct 

func (f Publications_Callback_write_Results_Future) Struct() (Publications_Callback_write_Results, error)

type Publications_Callback_write_Results_List 

type Publications_Callback_write_Results_List = capnp.StructList[Publications_Callback_write_Results]

Publications_Callback_write_Results_List is a list of Publications_Callback_write_Results.

func NewPublications_Callback_write_Results_List 

func NewPublications_Callback_write_Results_List(s *capnp.Segment, sz int32) (Publications_Callback_write_Results_List, error)

NewPublications_Callback_write_Results creates a new list of Publications_Callback_write_Results.

type Publications_List 

type Publications_List = capnp.CapList[Publications]

Publications_List is a list of Publications.

func NewPublications_List 

func NewPublications_List(s *capnp.Segment, sz int32) (Publications_List, error)

NewPublications creates a new list of Publications.

type Publications_Server 

type Publications_Server interface {
	Create(context.Context, Publications_create) error

	Push(context.Context, Publications_push) error

	Upload(context.Context, Publications_upload) error

	List(context.Context, Publications_list) error

	Deals(context.Context, Publications_deals) error

	LatestDeals(context.Context, Publications_latestDeals) error
}

A Publications_Server is a Publications with a local implementation.

type Publications_create 

type Publications_create struct {
	*server.Call
}

Publications_create holds the state for a server call to Publications.create. See server.Call for documentation.

func (Publications_create) AllocResults 

func (c Publications_create) AllocResults() (Publications_create_Results, error)

AllocResults allocates the results struct.

func (Publications_create) Args 

func (c Publications_create) Args() Publications_create_Params

Args returns the call's arguments.

type Publications_create_Params 

type Publications_create_Params capnp.Struct

func NewPublications_create_Params 

func NewPublications_create_Params(s *capnp.Segment) (Publications_create_Params, error)

func NewRootPublications_create_Params 

func NewRootPublications_create_Params(s *capnp.Segment) (Publications_create_Params, error)

func ReadRootPublications_create_Params 

func ReadRootPublications_create_Params(msg *capnp.Message) (Publications_create_Params, error)

func (Publications_create_Params) Cache_duration 

func (s Publications_create_Params) Cache_duration() int64

func (Publications_create_Params) DecodeFromPtr 

func (Publications_create_Params) DecodeFromPtr(p capnp.Ptr) Publications_create_Params

func (Publications_create_Params) EncodeAsPtr 

func (s Publications_create_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_create_Params) HasNs 

func (s Publications_create_Params) HasNs() bool

func (Publications_create_Params) HasOwner 

func (s Publications_create_Params) HasOwner() bool

func (Publications_create_Params) HasRel 

func (s Publications_create_Params) HasRel() bool

func (Publications_create_Params) HasSchema 

func (s Publications_create_Params) HasSchema() bool

func (Publications_create_Params) IsValid 

func (s Publications_create_Params) IsValid() bool

func (Publications_create_Params) Message 

func (s Publications_create_Params) Message() *capnp.Message

func (Publications_create_Params) NewSchema 

func (s Publications_create_Params) NewSchema() (capnp2.Schema, error)

NewSchema sets the schema field to a newly allocated capnp2.Schema struct, preferring placement in s's segment.

func (Publications_create_Params) Ns 

func (s Publications_create_Params) Ns() (string, error)

func (Publications_create_Params) NsBytes 

func (s Publications_create_Params) NsBytes() ([]byte, error)

func (Publications_create_Params) Owner 

func (s Publications_create_Params) Owner() ([]byte, error)

func (Publications_create_Params) Rel 

func (s Publications_create_Params) Rel() (string, error)

func (Publications_create_Params) RelBytes 

func (s Publications_create_Params) RelBytes() ([]byte, error)

func (Publications_create_Params) Schema 

func (s Publications_create_Params) Schema() (capnp2.Schema, error)

func (Publications_create_Params) Segment 

func (s Publications_create_Params) Segment() *capnp.Segment

func (Publications_create_Params) SetCache_duration 

func (s Publications_create_Params) SetCache_duration(v int64)

func (Publications_create_Params) SetNs 

func (s Publications_create_Params) SetNs(v string) error

func (Publications_create_Params) SetOwner 

func (s Publications_create_Params) SetOwner(v []byte) error

func (Publications_create_Params) SetRel 

func (s Publications_create_Params) SetRel(v string) error

func (Publications_create_Params) SetSchema 

func (s Publications_create_Params) SetSchema(v capnp2.Schema) error

func (Publications_create_Params) String 

func (s Publications_create_Params) String() string

func (Publications_create_Params) ToPtr 

func (s Publications_create_Params) ToPtr() capnp.Ptr

type Publications_create_Params_Future 

type Publications_create_Params_Future struct{ *capnp.Future }

Publications_create_Params_Future is a wrapper for a Publications_create_Params promised by a client call.

func (Publications_create_Params_Future) Schema 

func (p Publications_create_Params_Future) Schema() capnp2.Schema_Future

func (Publications_create_Params_Future) Struct 

func (f Publications_create_Params_Future) Struct() (Publications_create_Params, error)

type Publications_create_Params_List 

type Publications_create_Params_List = capnp.StructList[Publications_create_Params]

Publications_create_Params_List is a list of Publications_create_Params.

func NewPublications_create_Params_List 

func NewPublications_create_Params_List(s *capnp.Segment, sz int32) (Publications_create_Params_List, error)

NewPublications_create_Params creates a new list of Publications_create_Params.

type Publications_create_Results 

type Publications_create_Results capnp.Struct

func NewPublications_create_Results 

func NewPublications_create_Results(s *capnp.Segment) (Publications_create_Results, error)

func NewRootPublications_create_Results 

func NewRootPublications_create_Results(s *capnp.Segment) (Publications_create_Results, error)

func ReadRootPublications_create_Results 

func ReadRootPublications_create_Results(msg *capnp.Message) (Publications_create_Results, error)

func (Publications_create_Results) DecodeFromPtr 

func (Publications_create_Results) DecodeFromPtr(p capnp.Ptr) Publications_create_Results

func (Publications_create_Results) EncodeAsPtr 

func (s Publications_create_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_create_Results) Exists 

func (s Publications_create_Results) Exists() bool

func (Publications_create_Results) IsValid 

func (s Publications_create_Results) IsValid() bool

func (Publications_create_Results) Message 

func (s Publications_create_Results) Message() *capnp.Message

func (Publications_create_Results) Segment 

func (s Publications_create_Results) Segment() *capnp.Segment

func (Publications_create_Results) SetExists 

func (s Publications_create_Results) SetExists(v bool)

func (Publications_create_Results) String 

func (s Publications_create_Results) String() string

func (Publications_create_Results) ToPtr 

func (s Publications_create_Results) ToPtr() capnp.Ptr

type Publications_create_Results_Future 

type Publications_create_Results_Future struct{ *capnp.Future }

Publications_create_Results_Future is a wrapper for a Publications_create_Results promised by a client call.

func (Publications_create_Results_Future) Struct 

func (f Publications_create_Results_Future) Struct() (Publications_create_Results, error)

type Publications_create_Results_List 

type Publications_create_Results_List = capnp.StructList[Publications_create_Results]

Publications_create_Results_List is a list of Publications_create_Results.

func NewPublications_create_Results_List 

func NewPublications_create_Results_List(s *capnp.Segment, sz int32) (Publications_create_Results_List, error)

NewPublications_create_Results creates a new list of Publications_create_Results.

type Publications_deals 

type Publications_deals struct {
	*server.Call
}

Publications_deals holds the state for a server call to Publications.deals. See server.Call for documentation.

func (Publications_deals) AllocResults 

func (c Publications_deals) AllocResults() (Publications_deals_Results, error)

AllocResults allocates the results struct.

func (Publications_deals) Args 

func (c Publications_deals) Args() Publications_deals_Params

Args returns the call's arguments.

type Publications_deals_Params 

type Publications_deals_Params capnp.Struct

func NewPublications_deals_Params 

func NewPublications_deals_Params(s *capnp.Segment) (Publications_deals_Params, error)

func NewRootPublications_deals_Params 

func NewRootPublications_deals_Params(s *capnp.Segment) (Publications_deals_Params, error)

func ReadRootPublications_deals_Params 

func ReadRootPublications_deals_Params(msg *capnp.Message) (Publications_deals_Params, error)

func (Publications_deals_Params) After 

func (s Publications_deals_Params) After() int64

func (Publications_deals_Params) Before 

func (s Publications_deals_Params) Before() int64

func (Publications_deals_Params) DecodeFromPtr 

func (Publications_deals_Params) DecodeFromPtr(p capnp.Ptr) Publications_deals_Params

func (Publications_deals_Params) EncodeAsPtr 

func (s Publications_deals_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_deals_Params) HasNs 

func (s Publications_deals_Params) HasNs() bool

func (Publications_deals_Params) HasRel 

func (s Publications_deals_Params) HasRel() bool

func (Publications_deals_Params) IsValid 

func (s Publications_deals_Params) IsValid() bool

func (Publications_deals_Params) Limit 

func (s Publications_deals_Params) Limit() uint32

func (Publications_deals_Params) Message 

func (s Publications_deals_Params) Message() *capnp.Message

func (Publications_deals_Params) Ns 

func (s Publications_deals_Params) Ns() (string, error)

func (Publications_deals_Params) NsBytes 

func (s Publications_deals_Params) NsBytes() ([]byte, error)

func (Publications_deals_Params) Offset 

func (s Publications_deals_Params) Offset() uint64

func (Publications_deals_Params) Rel 

func (s Publications_deals_Params) Rel() (string, error)

func (Publications_deals_Params) RelBytes 

func (s Publications_deals_Params) RelBytes() ([]byte, error)

func (Publications_deals_Params) Segment 

func (s Publications_deals_Params) Segment() *capnp.Segment

func (Publications_deals_Params) SetAfter 

func (s Publications_deals_Params) SetAfter(v int64)

func (Publications_deals_Params) SetBefore 

func (s Publications_deals_Params) SetBefore(v int64)

func (Publications_deals_Params) SetLimit 

func (s Publications_deals_Params) SetLimit(v uint32)

func (Publications_deals_Params) SetNs 

func (s Publications_deals_Params) SetNs(v string) error

func (Publications_deals_Params) SetOffset 

func (s Publications_deals_Params) SetOffset(v uint64)

func (Publications_deals_Params) SetRel 

func (s Publications_deals_Params) SetRel(v string) error

func (Publications_deals_Params) String 

func (s Publications_deals_Params) String() string

func (Publications_deals_Params) ToPtr 

func (s Publications_deals_Params) ToPtr() capnp.Ptr

type Publications_deals_Params_Future 

type Publications_deals_Params_Future struct{ *capnp.Future }

Publications_deals_Params_Future is a wrapper for a Publications_deals_Params promised by a client call.

func (Publications_deals_Params_Future) Struct 

func (f Publications_deals_Params_Future) Struct() (Publications_deals_Params, error)

type Publications_deals_Params_List 

type Publications_deals_Params_List = capnp.StructList[Publications_deals_Params]

Publications_deals_Params_List is a list of Publications_deals_Params.

func NewPublications_deals_Params_List 

func NewPublications_deals_Params_List(s *capnp.Segment, sz int32) (Publications_deals_Params_List, error)

NewPublications_deals_Params creates a new list of Publications_deals_Params.

type Publications_deals_Results 

type Publications_deals_Results capnp.Struct

func NewPublications_deals_Results 

func NewPublications_deals_Results(s *capnp.Segment) (Publications_deals_Results, error)

func NewRootPublications_deals_Results 

func NewRootPublications_deals_Results(s *capnp.Segment) (Publications_deals_Results, error)

func ReadRootPublications_deals_Results 

func ReadRootPublications_deals_Results(msg *capnp.Message) (Publications_deals_Results, error)

func (Publications_deals_Results) Deals 

func (s Publications_deals_Results) Deals() (capnp2.DealInfo_List, error)

func (Publications_deals_Results) DecodeFromPtr 

func (Publications_deals_Results) DecodeFromPtr(p capnp.Ptr) Publications_deals_Results

func (Publications_deals_Results) EncodeAsPtr 

func (s Publications_deals_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_deals_Results) HasDeals 

func (s Publications_deals_Results) HasDeals() bool

func (Publications_deals_Results) IsValid 

func (s Publications_deals_Results) IsValid() bool

func (Publications_deals_Results) Message 

func (s Publications_deals_Results) Message() *capnp.Message

func (Publications_deals_Results) NewDeals 

func (s Publications_deals_Results) NewDeals(n int32) (capnp2.DealInfo_List, error)

NewDeals sets the deals field to a newly allocated capnp2.DealInfo_List, preferring placement in s's segment.

func (Publications_deals_Results) Segment 

func (s Publications_deals_Results) Segment() *capnp.Segment

func (Publications_deals_Results) SetDeals 

func (s Publications_deals_Results) SetDeals(v capnp2.DealInfo_List) error

func (Publications_deals_Results) String 

func (s Publications_deals_Results) String() string

func (Publications_deals_Results) ToPtr 

func (s Publications_deals_Results) ToPtr() capnp.Ptr

type Publications_deals_Results_Future 

type Publications_deals_Results_Future struct{ *capnp.Future }

Publications_deals_Results_Future is a wrapper for a Publications_deals_Results promised by a client call.

func (Publications_deals_Results_Future) Struct 

func (f Publications_deals_Results_Future) Struct() (Publications_deals_Results, error)

type Publications_deals_Results_List 

type Publications_deals_Results_List = capnp.StructList[Publications_deals_Results]

Publications_deals_Results_List is a list of Publications_deals_Results.

func NewPublications_deals_Results_List 

func NewPublications_deals_Results_List(s *capnp.Segment, sz int32) (Publications_deals_Results_List, error)

NewPublications_deals_Results creates a new list of Publications_deals_Results.

type Publications_latestDeals 

type Publications_latestDeals struct {
	*server.Call
}

Publications_latestDeals holds the state for a server call to Publications.latestDeals. See server.Call for documentation.

func (Publications_latestDeals) AllocResults 

func (c Publications_latestDeals) AllocResults() (Publications_latestDeals_Results, error)

AllocResults allocates the results struct.

func (Publications_latestDeals) Args 

func (c Publications_latestDeals) Args() Publications_latestDeals_Params

Args returns the call's arguments.

type Publications_latestDeals_Params 

type Publications_latestDeals_Params capnp.Struct

func NewPublications_latestDeals_Params 

func NewPublications_latestDeals_Params(s *capnp.Segment) (Publications_latestDeals_Params, error)

func NewRootPublications_latestDeals_Params 

func NewRootPublications_latestDeals_Params(s *capnp.Segment) (Publications_latestDeals_Params, error)

func ReadRootPublications_latestDeals_Params 

func ReadRootPublications_latestDeals_Params(msg *capnp.Message) (Publications_latestDeals_Params, error)

func (Publications_latestDeals_Params) After 

func (s Publications_latestDeals_Params) After() int64

func (Publications_latestDeals_Params) Before 

func (s Publications_latestDeals_Params) Before() int64

func (Publications_latestDeals_Params) DecodeFromPtr 

func (Publications_latestDeals_Params) DecodeFromPtr(p capnp.Ptr) Publications_latestDeals_Params

func (Publications_latestDeals_Params) EncodeAsPtr 

func (s Publications_latestDeals_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_latestDeals_Params) HasNs 

func (s Publications_latestDeals_Params) HasNs() bool

func (Publications_latestDeals_Params) HasRel 

func (s Publications_latestDeals_Params) HasRel() bool

func (Publications_latestDeals_Params) IsValid 

func (s Publications_latestDeals_Params) IsValid() bool

func (Publications_latestDeals_Params) Message 

func (s Publications_latestDeals_Params) Message() *capnp.Message

func (Publications_latestDeals_Params) N 

func (s Publications_latestDeals_Params) N() uint32

func (Publications_latestDeals_Params) Ns 

func (s Publications_latestDeals_Params) Ns() (string, error)

func (Publications_latestDeals_Params) NsBytes 

func (s Publications_latestDeals_Params) NsBytes() ([]byte, error)

func (Publications_latestDeals_Params) Rel 

func (s Publications_latestDeals_Params) Rel() (string, error)

func (Publications_latestDeals_Params) RelBytes 

func (s Publications_latestDeals_Params) RelBytes() ([]byte, error)

func (Publications_latestDeals_Params) Segment 

func (s Publications_latestDeals_Params) Segment() *capnp.Segment

func (Publications_latestDeals_Params) SetAfter 

func (s Publications_latestDeals_Params) SetAfter(v int64)

func (Publications_latestDeals_Params) SetBefore 

func (s Publications_latestDeals_Params) SetBefore(v int64)

func (Publications_latestDeals_Params) SetN 

func (s Publications_latestDeals_Params) SetN(v uint32)

func (Publications_latestDeals_Params) SetNs 

func (s Publications_latestDeals_Params) SetNs(v string) error

func (Publications_latestDeals_Params) SetRel 

func (s Publications_latestDeals_Params) SetRel(v string) error

func (Publications_latestDeals_Params) String 

func (s Publications_latestDeals_Params) String() string

func (Publications_latestDeals_Params) ToPtr 

func (s Publications_latestDeals_Params) ToPtr() capnp.Ptr

type Publications_latestDeals_Params_Future 

type Publications_latestDeals_Params_Future struct{ *capnp.Future }

Publications_latestDeals_Params_Future is a wrapper for a Publications_latestDeals_Params promised by a client call.

func (Publications_latestDeals_Params_Future) Struct 

func (f Publications_latestDeals_Params_Future) Struct() (Publications_latestDeals_Params, error)

type Publications_latestDeals_Params_List 

type Publications_latestDeals_Params_List = capnp.StructList[Publications_latestDeals_Params]

Publications_latestDeals_Params_List is a list of Publications_latestDeals_Params.

func NewPublications_latestDeals_Params_List 

func NewPublications_latestDeals_Params_List(s *capnp.Segment, sz int32) (Publications_latestDeals_Params_List, error)

NewPublications_latestDeals_Params creates a new list of Publications_latestDeals_Params.

type Publications_latestDeals_Results 

type Publications_latestDeals_Results capnp.Struct

func NewPublications_latestDeals_Results 

func NewPublications_latestDeals_Results(s *capnp.Segment) (Publications_latestDeals_Results, error)

func NewRootPublications_latestDeals_Results 

func NewRootPublications_latestDeals_Results(s *capnp.Segment) (Publications_latestDeals_Results, error)

func ReadRootPublications_latestDeals_Results 

func ReadRootPublications_latestDeals_Results(msg *capnp.Message) (Publications_latestDeals_Results, error)

func (Publications_latestDeals_Results) Deals 

func (s Publications_latestDeals_Results) Deals() (capnp2.DealInfo_List, error)

func (Publications_latestDeals_Results) DecodeFromPtr 

func (Publications_latestDeals_Results) DecodeFromPtr(p capnp.Ptr) Publications_latestDeals_Results

func (Publications_latestDeals_Results) EncodeAsPtr 

func (s Publications_latestDeals_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_latestDeals_Results) HasDeals 

func (s Publications_latestDeals_Results) HasDeals() bool

func (Publications_latestDeals_Results) IsValid 

func (s Publications_latestDeals_Results) IsValid() bool

func (Publications_latestDeals_Results) Message 

func (s Publications_latestDeals_Results) Message() *capnp.Message

func (Publications_latestDeals_Results) NewDeals 

func (s Publications_latestDeals_Results) NewDeals(n int32) (capnp2.DealInfo_List, error)

NewDeals sets the deals field to a newly allocated capnp2.DealInfo_List, preferring placement in s's segment.

func (Publications_latestDeals_Results) Segment 

func (s Publications_latestDeals_Results) Segment() *capnp.Segment

func (Publications_latestDeals_Results) SetDeals 

func (s Publications_latestDeals_Results) SetDeals(v capnp2.DealInfo_List) error

func (Publications_latestDeals_Results) String 

func (s Publications_latestDeals_Results) String() string

func (Publications_latestDeals_Results) ToPtr 

func (s Publications_latestDeals_Results) ToPtr() capnp.Ptr

type Publications_latestDeals_Results_Future 

type Publications_latestDeals_Results_Future struct{ *capnp.Future }

Publications_latestDeals_Results_Future is a wrapper for a Publications_latestDeals_Results promised by a client call.

func (Publications_latestDeals_Results_Future) Struct 

func (f Publications_latestDeals_Results_Future) Struct() (Publications_latestDeals_Results, error)

type Publications_latestDeals_Results_List 

type Publications_latestDeals_Results_List = capnp.StructList[Publications_latestDeals_Results]

Publications_latestDeals_Results_List is a list of Publications_latestDeals_Results.

func NewPublications_latestDeals_Results_List 

func NewPublications_latestDeals_Results_List(s *capnp.Segment, sz int32) (Publications_latestDeals_Results_List, error)

NewPublications_latestDeals_Results creates a new list of Publications_latestDeals_Results.

type Publications_list 

type Publications_list struct {
	*server.Call
}

Publications_list holds the state for a server call to Publications.list. See server.Call for documentation.

func (Publications_list) AllocResults 

func (c Publications_list) AllocResults() (Publications_list_Results, error)

AllocResults allocates the results struct.

func (Publications_list) Args 

func (c Publications_list) Args() Publications_list_Params

Args returns the call's arguments.

type Publications_list_Params 

type Publications_list_Params capnp.Struct

func NewPublications_list_Params 

func NewPublications_list_Params(s *capnp.Segment) (Publications_list_Params, error)

func NewRootPublications_list_Params 

func NewRootPublications_list_Params(s *capnp.Segment) (Publications_list_Params, error)

func ReadRootPublications_list_Params 

func ReadRootPublications_list_Params(msg *capnp.Message) (Publications_list_Params, error)

func (Publications_list_Params) DecodeFromPtr 

func (Publications_list_Params) DecodeFromPtr(p capnp.Ptr) Publications_list_Params

func (Publications_list_Params) EncodeAsPtr 

func (s Publications_list_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_list_Params) HasOwner 

func (s Publications_list_Params) HasOwner() bool

func (Publications_list_Params) IsValid 

func (s Publications_list_Params) IsValid() bool

func (Publications_list_Params) Message 

func (s Publications_list_Params) Message() *capnp.Message

func (Publications_list_Params) Owner 

func (s Publications_list_Params) Owner() ([]byte, error)

func (Publications_list_Params) Segment 

func (s Publications_list_Params) Segment() *capnp.Segment

func (Publications_list_Params) SetOwner 

func (s Publications_list_Params) SetOwner(v []byte) error

func (Publications_list_Params) String 

func (s Publications_list_Params) String() string

func (Publications_list_Params) ToPtr 

func (s Publications_list_Params) ToPtr() capnp.Ptr

type Publications_list_Params_Future 

type Publications_list_Params_Future struct{ *capnp.Future }

Publications_list_Params_Future is a wrapper for a Publications_list_Params promised by a client call.

func (Publications_list_Params_Future) Struct 

func (f Publications_list_Params_Future) Struct() (Publications_list_Params, error)

type Publications_list_Params_List 

type Publications_list_Params_List = capnp.StructList[Publications_list_Params]

Publications_list_Params_List is a list of Publications_list_Params.

func NewPublications_list_Params_List 

func NewPublications_list_Params_List(s *capnp.Segment, sz int32) (Publications_list_Params_List, error)

NewPublications_list_Params creates a new list of Publications_list_Params.

type Publications_list_Results 

type Publications_list_Results capnp.Struct

func NewPublications_list_Results 

func NewPublications_list_Results(s *capnp.Segment) (Publications_list_Results, error)

func NewRootPublications_list_Results 

func NewRootPublications_list_Results(s *capnp.Segment) (Publications_list_Results, error)

func ReadRootPublications_list_Results 

func ReadRootPublications_list_Results(msg *capnp.Message) (Publications_list_Results, error)

func (Publications_list_Results) DecodeFromPtr 

func (Publications_list_Results) DecodeFromPtr(p capnp.Ptr) Publications_list_Results

func (Publications_list_Results) EncodeAsPtr 

func (s Publications_list_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_list_Results) HasPublications 

func (s Publications_list_Results) HasPublications() bool

func (Publications_list_Results) IsValid 

func (s Publications_list_Results) IsValid() bool

func (Publications_list_Results) Message 

func (s Publications_list_Results) Message() *capnp.Message

func (Publications_list_Results) NewPublications 

func (s Publications_list_Results) NewPublications(n int32) (capnp.TextList, error)

NewPublications sets the publications field to a newly allocated capnp.TextList, preferring placement in s's segment.

func (Publications_list_Results) Publications 

func (s Publications_list_Results) Publications() (capnp.TextList, error)

func (Publications_list_Results) Segment 

func (s Publications_list_Results) Segment() *capnp.Segment

func (Publications_list_Results) SetPublications 

func (s Publications_list_Results) SetPublications(v capnp.TextList) error

func (Publications_list_Results) String 

func (s Publications_list_Results) String() string

func (Publications_list_Results) ToPtr 

func (s Publications_list_Results) ToPtr() capnp.Ptr

type Publications_list_Results_Future 

type Publications_list_Results_Future struct{ *capnp.Future }

Publications_list_Results_Future is a wrapper for a Publications_list_Results promised by a client call.

func (Publications_list_Results_Future) Struct 

func (f Publications_list_Results_Future) Struct() (Publications_list_Results, error)

type Publications_list_Results_List 

type Publications_list_Results_List = capnp.StructList[Publications_list_Results]

Publications_list_Results_List is a list of Publications_list_Results.

func NewPublications_list_Results_List 

func NewPublications_list_Results_List(s *capnp.Segment, sz int32) (Publications_list_Results_List, error)

NewPublications_list_Results creates a new list of Publications_list_Results.

type Publications_push 

type Publications_push struct {
	*server.Call
}

Publications_push holds the state for a server call to Publications.push. See server.Call for documentation.

func (Publications_push) AllocResults 

func (c Publications_push) AllocResults() (Publications_push_Results, error)

AllocResults allocates the results struct.

func (Publications_push) Args 

func (c Publications_push) Args() Publications_push_Params

Args returns the call's arguments.

type Publications_push_Params 

type Publications_push_Params capnp.Struct

func NewPublications_push_Params 

func NewPublications_push_Params(s *capnp.Segment) (Publications_push_Params, error)

func NewRootPublications_push_Params 

func NewRootPublications_push_Params(s *capnp.Segment) (Publications_push_Params, error)

func ReadRootPublications_push_Params 

func ReadRootPublications_push_Params(msg *capnp.Message) (Publications_push_Params, error)

func (Publications_push_Params) DecodeFromPtr 

func (Publications_push_Params) DecodeFromPtr(p capnp.Ptr) Publications_push_Params

func (Publications_push_Params) EncodeAsPtr 

func (s Publications_push_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_push_Params) HasNs 

func (s Publications_push_Params) HasNs() bool

func (Publications_push_Params) HasRel 

func (s Publications_push_Params) HasRel() bool

func (Publications_push_Params) HasSig 

func (s Publications_push_Params) HasSig() bool

func (Publications_push_Params) HasTx 

func (s Publications_push_Params) HasTx() bool

func (Publications_push_Params) IsValid 

func (s Publications_push_Params) IsValid() bool

func (Publications_push_Params) Message 

func (s Publications_push_Params) Message() *capnp.Message

func (Publications_push_Params) NewTx 

func (s Publications_push_Params) NewTx() (capnp2.Tx, error)

NewTx sets the tx field to a newly allocated capnp2.Tx struct, preferring placement in s's segment.

func (Publications_push_Params) Ns 

func (s Publications_push_Params) Ns() (string, error)

func (Publications_push_Params) NsBytes 

func (s Publications_push_Params) NsBytes() ([]byte, error)

func (Publications_push_Params) Rel 

func (s Publications_push_Params) Rel() (string, error)

func (Publications_push_Params) RelBytes 

func (s Publications_push_Params) RelBytes() ([]byte, error)

func (Publications_push_Params) Segment 

func (s Publications_push_Params) Segment() *capnp.Segment

func (Publications_push_Params) SetNs 

func (s Publications_push_Params) SetNs(v string) error

func (Publications_push_Params) SetRel 

func (s Publications_push_Params) SetRel(v string) error

func (Publications_push_Params) SetSig 

func (s Publications_push_Params) SetSig(v []byte) error

func (Publications_push_Params) SetTx 

func (s Publications_push_Params) SetTx(v capnp2.Tx) error

func (Publications_push_Params) Sig 

func (s Publications_push_Params) Sig() ([]byte, error)

func (Publications_push_Params) String 

func (s Publications_push_Params) String() string

func (Publications_push_Params) ToPtr 

func (s Publications_push_Params) ToPtr() capnp.Ptr

func (Publications_push_Params) Tx 

func (s Publications_push_Params) Tx() (capnp2.Tx, error)

type Publications_push_Params_Future 

type Publications_push_Params_Future struct{ *capnp.Future }

Publications_push_Params_Future is a wrapper for a Publications_push_Params promised by a client call.

func (Publications_push_Params_Future) Struct 

func (f Publications_push_Params_Future) Struct() (Publications_push_Params, error)

func (Publications_push_Params_Future) Tx 

func (p Publications_push_Params_Future) Tx() capnp2.Tx_Future

type Publications_push_Params_List 

type Publications_push_Params_List = capnp.StructList[Publications_push_Params]

Publications_push_Params_List is a list of Publications_push_Params.

func NewPublications_push_Params_List 

func NewPublications_push_Params_List(s *capnp.Segment, sz int32) (Publications_push_Params_List, error)

NewPublications_push_Params creates a new list of Publications_push_Params.

type Publications_push_Results 

type Publications_push_Results capnp.Struct

func NewPublications_push_Results 

func NewPublications_push_Results(s *capnp.Segment) (Publications_push_Results, error)

func NewRootPublications_push_Results 

func NewRootPublications_push_Results(s *capnp.Segment) (Publications_push_Results, error)

func ReadRootPublications_push_Results 

func ReadRootPublications_push_Results(msg *capnp.Message) (Publications_push_Results, error)

func (Publications_push_Results) DecodeFromPtr 

func (Publications_push_Results) DecodeFromPtr(p capnp.Ptr) Publications_push_Results

func (Publications_push_Results) EncodeAsPtr 

func (s Publications_push_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_push_Results) IsValid 

func (s Publications_push_Results) IsValid() bool

func (Publications_push_Results) Message 

func (s Publications_push_Results) Message() *capnp.Message

func (Publications_push_Results) Segment 

func (s Publications_push_Results) Segment() *capnp.Segment

func (Publications_push_Results) String 

func (s Publications_push_Results) String() string

func (Publications_push_Results) ToPtr 

func (s Publications_push_Results) ToPtr() capnp.Ptr

type Publications_push_Results_Future 

type Publications_push_Results_Future struct{ *capnp.Future }

Publications_push_Results_Future is a wrapper for a Publications_push_Results promised by a client call.

func (Publications_push_Results_Future) Struct 

func (f Publications_push_Results_Future) Struct() (Publications_push_Results, error)

type Publications_push_Results_List 

type Publications_push_Results_List = capnp.StructList[Publications_push_Results]

Publications_push_Results_List is a list of Publications_push_Results.

func NewPublications_push_Results_List 

func NewPublications_push_Results_List(s *capnp.Segment, sz int32) (Publications_push_Results_List, error)

NewPublications_push_Results creates a new list of Publications_push_Results.

type Publications_upload 

type Publications_upload struct {
	*server.Call
}

Publications_upload holds the state for a server call to Publications.upload. See server.Call for documentation.

func (Publications_upload) AllocResults 

func (c Publications_upload) AllocResults() (Publications_upload_Results, error)

AllocResults allocates the results struct.

func (Publications_upload) Args 

func (c Publications_upload) Args() Publications_upload_Params

Args returns the call's arguments.

type Publications_upload_Params 

type Publications_upload_Params capnp.Struct

func NewPublications_upload_Params 

func NewPublications_upload_Params(s *capnp.Segment) (Publications_upload_Params, error)

func NewRootPublications_upload_Params 

func NewRootPublications_upload_Params(s *capnp.Segment) (Publications_upload_Params, error)

func ReadRootPublications_upload_Params 

func ReadRootPublications_upload_Params(msg *capnp.Message) (Publications_upload_Params, error)

func (Publications_upload_Params) DecodeFromPtr 

func (Publications_upload_Params) DecodeFromPtr(p capnp.Ptr) Publications_upload_Params

func (Publications_upload_Params) EncodeAsPtr 

func (s Publications_upload_Params) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_upload_Params) HasNs 

func (s Publications_upload_Params) HasNs() bool

func (Publications_upload_Params) HasRel 

func (s Publications_upload_Params) HasRel() bool

func (Publications_upload_Params) IsValid 

func (s Publications_upload_Params) IsValid() bool

func (Publications_upload_Params) Message 

func (s Publications_upload_Params) Message() *capnp.Message

func (Publications_upload_Params) Ns 

func (s Publications_upload_Params) Ns() (string, error)

func (Publications_upload_Params) NsBytes 

func (s Publications_upload_Params) NsBytes() ([]byte, error)

func (Publications_upload_Params) Rel 

func (s Publications_upload_Params) Rel() (string, error)

func (Publications_upload_Params) RelBytes 

func (s Publications_upload_Params) RelBytes() ([]byte, error)

func (Publications_upload_Params) Segment 

func (s Publications_upload_Params) Segment() *capnp.Segment

func (Publications_upload_Params) SetNs 

func (s Publications_upload_Params) SetNs(v string) error

func (Publications_upload_Params) SetRel 

func (s Publications_upload_Params) SetRel(v string) error

func (Publications_upload_Params) SetSize 

func (s Publications_upload_Params) SetSize(v uint64)

func (Publications_upload_Params) SetTimestamp 

func (s Publications_upload_Params) SetTimestamp(v int64)

func (Publications_upload_Params) Size 

func (s Publications_upload_Params) Size() uint64

func (Publications_upload_Params) String 

func (s Publications_upload_Params) String() string

func (Publications_upload_Params) Timestamp 

func (s Publications_upload_Params) Timestamp() int64

func (Publications_upload_Params) ToPtr 

func (s Publications_upload_Params) ToPtr() capnp.Ptr

type Publications_upload_Params_Future 

type Publications_upload_Params_Future struct{ *capnp.Future }

Publications_upload_Params_Future is a wrapper for a Publications_upload_Params promised by a client call.

func (Publications_upload_Params_Future) Struct 

func (f Publications_upload_Params_Future) Struct() (Publications_upload_Params, error)

type Publications_upload_Params_List 

type Publications_upload_Params_List = capnp.StructList[Publications_upload_Params]

Publications_upload_Params_List is a list of Publications_upload_Params.

func NewPublications_upload_Params_List 

func NewPublications_upload_Params_List(s *capnp.Segment, sz int32) (Publications_upload_Params_List, error)

NewPublications_upload_Params creates a new list of Publications_upload_Params.

type Publications_upload_Results 

type Publications_upload_Results capnp.Struct

func NewPublications_upload_Results 

func NewPublications_upload_Results(s *capnp.Segment) (Publications_upload_Results, error)

func NewRootPublications_upload_Results 

func NewRootPublications_upload_Results(s *capnp.Segment) (Publications_upload_Results, error)

func ReadRootPublications_upload_Results 

func ReadRootPublications_upload_Results(msg *capnp.Message) (Publications_upload_Results, error)

func (Publications_upload_Results) Callback 

func (s Publications_upload_Results) Callback() Publications_Callback

func (Publications_upload_Results) DecodeFromPtr 

func (Publications_upload_Results) DecodeFromPtr(p capnp.Ptr) Publications_upload_Results

func (Publications_upload_Results) EncodeAsPtr 

func (s Publications_upload_Results) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr

func (Publications_upload_Results) HasCallback 

func (s Publications_upload_Results) HasCallback() bool

func (Publications_upload_Results) IsValid 

func (s Publications_upload_Results) IsValid() bool

func (Publications_upload_Results) Message 

func (s Publications_upload_Results) Message() *capnp.Message

func (Publications_upload_Results) Segment 

func (s Publications_upload_Results) Segment() *capnp.Segment

func (Publications_upload_Results) SetCallback 

func (s Publications_upload_Results) SetCallback(v Publications_Callback) error

func (Publications_upload_Results) String 

func (s Publications_upload_Results) String() string

func (Publications_upload_Results) ToPtr 

func (s Publications_upload_Results) ToPtr() capnp.Ptr

type Publications_upload_Results_Future 

type Publications_upload_Results_Future struct{ *capnp.Future }

Publications_upload_Results_Future is a wrapper for a Publications_upload_Results promised by a client call.

func (Publications_upload_Results_Future) Callback 

func (p Publications_upload_Results_Future) Callback() Publications_Callback

func (Publications_upload_Results_Future) Struct 

func (f Publications_upload_Results_Future) Struct() (Publications_upload_Results, error)

type Publications_upload_Results_List 

type Publications_upload_Results_List = capnp.StructList[Publications_upload_Results]

Publications_upload_Results_List is a list of Publications_upload_Results.

func NewPublications_upload_Results_List 

func NewPublications_upload_Results_List(s *capnp.Segment, sz int32) (Publications_upload_Results_List, error)

NewPublications_upload_Results creates a new list of Publications_upload_Results.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.