server

type Connection struct {
	Server        *Server
	Subscriptions map[interface{}]*Subscription
	Context       mutcontext.MutableContext
	Outgoing      chan *proto.Message
	Events        chan Event
	TickCloser    *TickCloser
	Stopcounter   int32
}

type Event interface{}

type EventConnectionInit struct {
	Parameters interface{}
}

type EventConnectionReadClosed struct {
}

type EventConnectionTerminate struct {
}

type EventConnectionTimerClosed struct {
}

type EventConnectionWriteClosed struct {
}

type EventOperationComplete struct {
	Id interface{}
}

type EventOperationStart struct {
	Id      interface{}
	Payload *proto.PayloadOperation
}

type EventOperationStop struct {
	Id interface{}
}

type Server struct {
	Upgrader        *websocket.Upgrader
	Schema          *graphql.Schema
	OnConnect       common.FuncConnectCallback
	OnOperation     common.FuncOperationCallback
	OnOperationDone common.FuncOperationDoneCallback
	OnDisconnect    common.FuncDisconnectCallback
	OnPlainInit     common.FuncPlainInit
	OnPlainFail     common.FuncPlainFail
	IgnorePlainHttp bool
	KeepAlive       time.Duration
}

type Subscription struct {
	Id      interface{}
	Payload *proto.PayloadOperation
	Context mutcontext.MutableContext
}

type TickCloser struct {
	Ticker  *time.Ticker
	Stopped chan bool
}