jsonrpc_any

Documentation

Index

• type Channel
• type ChannelConsumeRequest
• type ChannelConsumeResponse
• type ChannelInitRequest
• type ChannelInitResponse
• type ChannelProduceRequest
• type ChannelProduceResponse
• type UpdatesChannel

Types

type Channel

type Channel struct {
	UUID       string
	ExpireTime time.Time
	P          *router.ProducerChannel
	C          *router.ConsumerChannel
}

type ChannelConsumeRequest

type ChannelConsumeRequest struct {
	UUID       string        `json:"uuid"`
	Timeout    time.Duration `json:"-"`
	TimeoutStr string        `json:"timeout"`
	Limit      int           `json:"limit"`
}

type ChannelConsumeResponse

type ChannelConsumeResponse struct {
	Packets []types.Packet `json:"packets"`
	Code    int            `json:"code"`
}

type ChannelInitRequest

type ChannelInitRequest struct {
	UUID     string               `json:"uuid"`
	Producer bool                 `json:"producer"`
	Consumer bool                 `json:"consumer"`
	Accept   []router.RoutingRule `json:"accept"`
}

type ChannelInitResponse

type ChannelInitResponse struct {
	UUID string `json:"uuid"`
	Code int    `json:"code"`
}

type ChannelProduceRequest

type ChannelProduceRequest struct {
	UUID   string       `json:"uuid"`
	Packet types.Packet `json:"packet"`
}

type ChannelProduceResponse

type ChannelProduceResponse struct {
	Code int `json:"code"`
}

type UpdatesChannel

type UpdatesChannel <-chan *types.Packet