boat

package
v0.0.0-...-ae8612d Latest Latest
Warning

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

Go to latest
Published: Jul 2, 2019 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init

func Init(
	applicationId string,
	logger *logrus.Logger,
	stationCli stationpb.StationClient,
)

func NewGRPCServer

func NewGRPCServer(opts ...grpc.ServerOption) (*grpc.Server, error)

func NewLoopServer

func NewLoopServer(ctx context.Context, opts ...grpc.ServerOption) (*grpc.Server, io.Closer, error)

Types

type Session

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

func (*Session) Kickout

func (sess *Session) Kickout(err error)

func (*Session) Send

func (sess *Session) Send(m *msgpb.ServerPayload, ackWait time.Duration) error

func (*Session) Update

func (sess *Session) Update(uid, platform string)

type SessionStore

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

func NewSessionStore

func NewSessionStore() *SessionStore

func (*SessionStore) Delete

func (ss *SessionStore) Delete(sid string)

func (*SessionStore) Get

func (ss *SessionStore) Get(sid string) *Session

func (*SessionStore) NewSession

func (ss *SessionStore) NewSession() *Session

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL