hub

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

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

type DemoEnvOptions struct {
	GetUID        func() string
	OnDemoOrder   func(*hubpb.DemoOrder)
	OnDemoTrade   func(*pb.Trade)
	GetInstrument func(string) *pb.Instrument
}

type Packet struct {
	MsgType    int32
	RequestID  int32
	IsLast     int32
	BodyLength int32
	BodyList   [][]byte
}

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

type SyncAdapter struct {
	Data interface{}
	// contains filtered or unexported fields
}

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

type SyncPoolOptions struct {
	NewSyncAdapter func(brokerID, account string) (*SyncAdapter, error)
}