bridge

Documentation

Index

• func MethodDesc(desc rpc.InterfaceDesc, name string) rpc.MethodDesc
• func SeekAndSetBlessings(ctx *context.T, oauthProvider string, oauthToken string) error
• type Bridge
  • func NewBridge(ctx *context.T, disp rpc.Dispatcher) *Bridge
  • func (b *Bridge) GetCollection(ctx *context.T, call rpc.ServerCall, name string) (wire.CollectionServerStubMethods, error)
  • func (b *Bridge) GetDb(ctx *context.T, call rpc.ServerCall, name string) (wire.DatabaseServerStubMethods, error)
  • func (b *Bridge) GetGlobber(ctx *context.T, call rpc.ServerCall, name string) (rpc.ChildrenGlobber, error)
  • func (b *Bridge) GetRow(ctx *context.T, call rpc.ServerCall, name string) (wire.RowServerStubMethods, error)
  • func (b *Bridge) GetService(ctx *context.T, call rpc.ServerCall) (wire.ServiceServerStubMethods, error)
  • func (b *Bridge) NewCtxCall(suffix string, method rpc.MethodDesc) (*context.T, rpc.ServerCall)

Functions

func MethodDesc

func MethodDesc(desc rpc.InterfaceDesc, name string) rpc.MethodDesc

func SeekAndSetBlessings

func SeekAndSetBlessings(ctx *context.T, oauthProvider string, oauthToken string) error

SeekAndSetBlessings exchanges an OAuth token for blessings from the dev.v.io server. Currently, oauthProvider must be set to "google".

Types

type Bridge

type Bridge struct {
	Ctx      *context.T
	Shutdown v23.Shutdown
	Srv      rpc.Server
	Disp     rpc.Dispatcher
	Cleanup  func()
}

Bridge object, representing an in-process Syncbase singleton.

func NewBridge

func NewBridge(ctx *context.T, disp rpc.Dispatcher) *Bridge

func (*Bridge) GetCollection

func (b *Bridge) GetCollection(ctx *context.T, call rpc.ServerCall, name string) (wire.CollectionServerStubMethods, error)

func (*Bridge) GetDb

func (b *Bridge) GetDb(ctx *context.T, call rpc.ServerCall, name string) (wire.DatabaseServerStubMethods, error)

func (*Bridge) GetGlobber

func (b *Bridge) GetGlobber(ctx *context.T, call rpc.ServerCall, name string) (rpc.ChildrenGlobber, error)

func (*Bridge) GetRow

func (b *Bridge) GetRow(ctx *context.T, call rpc.ServerCall, name string) (wire.RowServerStubMethods, error)

func (*Bridge) GetService

func (b *Bridge) GetService(ctx *context.T, call rpc.ServerCall) (wire.ServiceServerStubMethods, error)

func (*Bridge) NewCtxCall

func (b *Bridge) NewCtxCall(suffix string, method rpc.MethodDesc) (*context.T, rpc.ServerCall)