centrifugoKit

Documentation

Index

• func NewClient(addrs []string, apiKey string, httpClient *http.Client) (*gocent.Client, error)
• type GrpcClient
  • func NewGrpcClient(hosts []string) (client *GrpcClient, err error)
  • func (client *GrpcClient) Batch(ctx context.Context) error
  • func (client *GrpcClient) Broadcast(ctx context.Context, channels []string, data []byte) error
  • func (client *GrpcClient) Presence(ctx context.Context, channel string) error
  • func (client *GrpcClient) PresenceStats(ctx context.Context, channel string) error
  • func (client *GrpcClient) Publish(ctx context.Context, channel string, data []byte) error

Functions

func NewClient

func NewClient(addrs []string, apiKey string, httpClient *http.Client) (*gocent.Client, error)

NewClient TODO: 待完善

@param addrs e.g.[]string{"http://localhost:8000/api"} @param apiKey centrifugo配置文件中的 api_key 项 @param httpClient 可以为nil（将使用默认值 httpClientKit.DefaultHttpClient）

Types

type GrpcClient

type GrpcClient struct {
}

func NewGrpcClient

func NewGrpcClient(hosts []string) (client *GrpcClient, err error)

func (*GrpcClient) Batch

func (client *GrpcClient) Batch(ctx context.Context) error

func (*GrpcClient) Broadcast

func (client *GrpcClient) Broadcast(ctx context.Context, channels []string, data []byte) error

func (*GrpcClient) Presence

func (client *GrpcClient) Presence(ctx context.Context, channel string) error

func (*GrpcClient) PresenceStats

func (client *GrpcClient) PresenceStats(ctx context.Context, channel string) error

func (*GrpcClient) Publish

func (client *GrpcClient) Publish(ctx context.Context, channel string, data []byte) error