federation

Documentation

Index

• type IFederation
  • func New(federationURL func() *url.URL, adminPortGetter func() int) (federation IFederation, cleanup func())
• type OffsetsChan

Types

type IFederation

type IFederation interface {
	Func(relativeURL string, body string, optFuncs ...coreutils.ReqOptFunc) (*coreutils.FuncResponse, error)
	UploadBLOB(appQName istructs.AppQName, wsid istructs.WSID, blobName string, blobMimeType string, blobContent []byte,
		optFuncs ...coreutils.ReqOptFunc) (blobID istructs.RecordID, err error)
	UploadBLOBs(appQName istructs.AppQName, wsid istructs.WSID, blobs []coreutils.BLOB, optFuncs ...coreutils.ReqOptFunc) (blobIDs []istructs.RecordID, err error)
	ReadBLOB(appQName istructs.AppQName, wsid istructs.WSID, blobID istructs.RecordID, optFuncs ...coreutils.ReqOptFunc) (*coreutils.HTTPResponse, error)
	URLStr() string
	Port() int
	N10NUpdate(key in10n.ProjectionKey, val int64, optFuncs ...coreutils.ReqOptFunc) error
	N10NSubscribe(projectionKey in10n.ProjectionKey) (offsetsChan OffsetsChan, unsubscribe func(), err error)
	AdminFunc(relativeURL string, body string, optFuncs ...coreutils.ReqOptFunc) (*coreutils.FuncResponse, error)
}

func New

func New(federationURL func() *url.URL, adminPortGetter func() int) (federation IFederation, cleanup func())

type OffsetsChan

type OffsetsChan chan istructs.Offset