func AllSessionIDs(gGroup) (out []string)

func MethodURL(s, mstring)string

type Attachable interface {Register(*grpc.Server)}

type Caller interface {Context()context.ContextSupports(methodstring)boolConn() *grpc.ClientConnSharedKey()string}

type Dialer func(ctxcontext.Context, protostring, meta map[string][]string) (net.Conn,error)

type Group interface {SessionIterator()Iterator}

funcNewGroup¶added inv0.8.0

func NewGroup(ids ...string)Group

type Iterator interface {NextSession()string}

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

funcNewManager¶

func NewManager() (*Manager,error)

NewManager returns a new Manager

func (*Manager)Any¶added inv0.8.0

func (sm *Manager) Any(ctxcontext.Context, gGroup, f func(context.Context,string,Caller)error)error

func (*Manager)Get¶

func (sm *Manager) Get(ctxcontext.Context, idstring, noWaitbool) (Caller,error)

Get returns a session by ID

func (*Manager)HandleConn¶

func (sm *Manager) HandleConn(ctxcontext.Context, connnet.Conn, opts map[string][]string)error

HandleConn handles an incoming raw connection

func (*Manager)HandleHTTPRequest¶

func (sm *Manager) HandleHTTPRequest(ctxcontext.Context, whttp.ResponseWriter, r *http.Request)error

HandleHTTPRequest handles an incoming HTTP request

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

funcNewSession¶

func NewSession(ctxcontext.Context, sharedKeystring) (*Session,error)

NewSession returns a new long running session

func (*Session)Allow¶

func (s *Session) Allow(aAttachable)

Allow enables a given service to be reachable through the grpc session

func (*Session)Close¶

func (s *Session) Close()error

Close closes the session

func (*Session)ID¶

func (s *Session) ID()string

ID returns unique identifier for the session

func (*Session)Run¶

func (s *Session) Run(ctxcontext.Context, dialerDialer)error

Run activates the session