sync

type BarrierRequest struct {
	State  string `json:"state"`
	Target int    `json:"target"`
}

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

type PublishRequest struct {
	Topic   string      `json:"topic"`
	Payload interface{} `json:"payload"`
}

type PublishResponse struct {
	Seq int `json:"seq"`
}

type Request struct {
	ID                 string              `json:"id"`
	IsCancel           bool                `json:"is_cancel"`
	PublishRequest     *PublishRequest     `json:"publish,omitempty"`
	SubscribeRequest   *SubscribeRequest   `json:"subscribe,omitempty"`
	BarrierRequest     *BarrierRequest     `json:"barrier,omitempty"`
	SignalEntryRequest *SignalEntryRequest `json:"signal_entry,omitempty"`
}

type Response struct {
	ID                  string               `json:"id"`
	Error               string               `json:"error"`
	PublishResponse     *PublishResponse     `json:"publish"`
	SubscribeResponse   string               `json:"subscribe"` // JSON encoded subscribe response.
	SignalEntryResponse *SignalEntryResponse `json:"signal_entry"`
}

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

type Service interface {
	io.Closer
	Publish(ctx context.Context, topic string, payload interface{}) (seq int, err error)
	Subscribe(ctx context.Context, topic string) (*subscription, error)
	Barrier(ctx context.Context, state string, target int) error
	SignalEntry(ctx context.Context, state string) (after int, err error)
}

type SignalEntryRequest struct {
	State string `json:"state"`
}

type SignalEntryResponse struct {
	Seq int `json:"seq"`
}

type SubscribeRequest struct {
	Topic string `json:"topic"`
}