dapr

Documentation

Index

• Constants
• func FakeConnection() (connection.Connection, func())
• func FakeNewConnection(ctx context.Context, config interface{}) (connection.Connection, error)
• func NewConnection(_ context.Context, config interface{}) (connection.Connection, error)
• type ClientConfig
• type Dapr
  • func (r *Dapr) CloseConnection() error
  • func (r *Dapr) Publish(_ context.Context, data interface{}, topic string) error
  • func (r *Dapr) UpdateConnection(_ context.Context, config interface{}) error
• type FakeDapr
  • func (r *FakeDapr) CloseConnection() error
  • func (r *FakeDapr) Publish(_ context.Context, _ interface{}, _ string) error
  • func (r *FakeDapr) UpdateConnection(_ context.Context, config interface{}) error

Constants

const (
	Name = "dapr"
)

Functions

func FakeConnection

func FakeConnection() (connection.Connection, func())

func FakeNewConnection

func FakeNewConnection(ctx context.Context, config interface{}) (connection.Connection, error)

Returns a fake client for dapr.

func NewConnection

func NewConnection(_ context.Context, config interface{}) (connection.Connection, error)

Returns a new client for dapr.

Types

type ClientConfig

type ClientConfig struct {
	// Name of the component to be used for pub sub messaging
	Component string `json:"component"`
}

type Dapr

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

Dapr represents driver for interacting with pub sub using dapr.

func (*Dapr) CloseConnection

func (r *Dapr) CloseConnection() error

func (*Dapr) Publish

func (r *Dapr) Publish(_ context.Context, data interface{}, topic string) error

func (*Dapr) UpdateConnection

func (r *Dapr) UpdateConnection(_ context.Context, config interface{}) error

type FakeDapr

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

func (*FakeDapr) CloseConnection

func (r *FakeDapr) CloseConnection() error

func (*FakeDapr) Publish

func (r *FakeDapr) Publish(_ context.Context, _ interface{}, _ string) error

func (*FakeDapr) UpdateConnection

func (r *FakeDapr) UpdateConnection(_ context.Context, config interface{}) error