client

Documentation

Index

• type Client
  • func NewClient(conn grpc.ClientConnInterface) *Client
  • func (c *Client) Topic(topic string) *Topic
• type Subscribe
  • func NewSubscribe(driver string, config interface{}) (*Subscribe, error)
  • func (s *Subscribe) Run(opt *SubscribeOptions) func()
• type SubscribeOptions
• type Topic
  • func (t *Topic) QueueCreate(c context.Context, queue string) error
  • func (t *Topic) QueueRemove(c context.Context, queue string) error
  • func (t *Topic) Send(c context.Context, body string) (string, error)

Types

type Client

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

func NewClient

func NewClient(conn grpc.ClientConnInterface) *Client

func (*Client) Topic

func (c *Client) Topic(topic string) *Topic

type Subscribe

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

func NewSubscribe

func NewSubscribe(driver string, config interface{}) (*Subscribe, error)

func (*Subscribe) Run

func (s *Subscribe) Run(opt *SubscribeOptions) func()

type SubscribeOptions

type SubscribeOptions struct {
	Topic      string
	Queue      string
	OnMessage  func(id string, body []byte) error
	OnError    func(err error)
	OnWaitting func()
}

type Topic

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

func (*Topic) QueueCreate

func (t *Topic) QueueCreate(c context.Context, queue string) error

func (*Topic) QueueRemove

func (t *Topic) QueueRemove(c context.Context, queue string) error

func (*Topic) Send

func (t *Topic) Send(c context.Context, body string) (string, error)