goredis

Documentation

Index

• type Client
  • func NewClient(serverURL string) (*Client, error)
  • func (c *Client) Publisher(_ context.Context, channelName string, _ *runRedis.ChannelBindings) (runRedis.Publisher, error)
  • func (c *Client) Subscriber(ctx context.Context, channelName string, _ *runRedis.ChannelBindings) (runRedis.Subscriber, error)
• type EnvelopeIn
  • func NewEnvelopeIn(msg *redis.Message) *EnvelopeIn
  • func (e *EnvelopeIn) Headers() run.Headers
  • func (e *EnvelopeIn) Read(p []byte) (n int, err error)
• type EnvelopeOut
  • func NewEnvelopeOut() *EnvelopeOut
  • func (e *EnvelopeOut) AsAny() any
  • func (e *EnvelopeOut) ResetPayload()
  • func (e *EnvelopeOut) SetBindings(_ runRedis.MessageBindings)
  • func (e *EnvelopeOut) SetContentType(contentType string)
  • func (e *EnvelopeOut) SetHeaders(headers run.Headers)
• type ImplementationRecord
• type PublishChannel
  • func (p PublishChannel) Close() error
  • func (p PublishChannel) Send(ctx context.Context, envelopes ...runRedis.EnvelopeWriter) error
• type SubscriberChannel
  • func (s SubscriberChannel) Receive(ctx context.Context, cb func(envelope runRedis.EnvelopeReader)) error

Types

type Client

type Client struct {
	*redis.Client
}

func NewClient

func NewClient(serverURL string) (*Client, error)

func (*Client) Publisher

func (c *Client) Publisher(_ context.Context, channelName string, _ *runRedis.ChannelBindings) (runRedis.Publisher, error)

func (*Client) Subscriber

func (c *Client) Subscriber(ctx context.Context, channelName string, _ *runRedis.ChannelBindings) (runRedis.Subscriber, error)

type EnvelopeIn

type EnvelopeIn struct {
	*redis.Message
	// contains filtered or unexported fields
}

func NewEnvelopeIn

func NewEnvelopeIn(msg *redis.Message) *EnvelopeIn

func (*EnvelopeIn) Headers

func (e *EnvelopeIn) Headers() run.Headers

func (*EnvelopeIn) Read

func (e *EnvelopeIn) Read(p []byte) (n int, err error)

type EnvelopeOut

type EnvelopeOut struct {
	*strings.Builder
	// contains filtered or unexported fields
}

func NewEnvelopeOut

func NewEnvelopeOut() *EnvelopeOut

func (*EnvelopeOut) AsAny

func (e *EnvelopeOut) AsAny() any

func (*EnvelopeOut) ResetPayload

func (e *EnvelopeOut) ResetPayload()

func (*EnvelopeOut) SetBindings

func (e *EnvelopeOut) SetBindings(_ runRedis.MessageBindings)

func (*EnvelopeOut) SetContentType

func (e *EnvelopeOut) SetContentType(contentType string)

func (*EnvelopeOut) SetHeaders

func (e *EnvelopeOut) SetHeaders(headers run.Headers)

type ImplementationRecord

type ImplementationRecord interface {
	AsAny() any
}

type PublishChannel

type PublishChannel struct {
	Client *redis.Client
	Name   string
}

func (PublishChannel) Close

func (p PublishChannel) Close() error

func (PublishChannel) Send

func (p PublishChannel) Send(ctx context.Context, envelopes ...runRedis.EnvelopeWriter) error

type SubscriberChannel

type SubscriberChannel struct {
	*redis.PubSub
	Name string
}

func (SubscriberChannel) Receive

func (s SubscriberChannel) Receive(ctx context.Context, cb func(envelope runRedis.EnvelopeReader)) error