Versions in this module Expand all Collapse all v1 v1.1.0 Aug 2, 2019 Changes in this version + func ConnectMixinBlaze(clientId, sessionId, sessionKey string) (*websocket.Conn, error) + func StartWxPaymentWatch(name string, db *durable.Database) + type Attachment struct + AttachmentId string + type BlazeMessage struct + Action string + Data interface{} + Error *session.Error + Id string + Params map[string]interface{} + type Event struct + func (event Event) Finalize(err error) error + type EventFactory struct + func NewEventFactory(size int64) *EventFactory + func (factory *EventFactory) Get() Event + func (factory *EventFactory) Insight() string + func (factory *EventFactory) InsightRoutine(logger *durable.Logger, tag string) + type Hub struct + func NewHub(db *durable.Database) *Hub + func (hub *Hub) StartService(name string) error + type MessageContext struct + DistributeDone chan bool + ReadBuffer chan MessageView + ReadDone chan bool + RecipientId map[string]time.Time + Transactions *tmap + WriteBuffer chan []byte + WriteDone chan bool + type MessageService struct + func (service *MessageService) Run(ctx context.Context) error + type MessageView struct + Category string + ConversationId string + CreatedAt time.Time + Data string + MessageId string + QuoteMessageId string + Source string + Status string + UpdatedAt time.Time + UserId string + type Service interface + Run func(context.Context) error + type TransferView struct + Amount string + AssetId string + CounterUserId string + CreatedAt time.Time + Memo string + SnapshotId string + TraceId string + Type string + type WxPaymentService struct
Go to main page