riff

Documentation

Index

• Constants
• func Close(i interface{})
• type Requester
  • func NewRequester(requestIDKey, consumerGroupID string, kafkaBrokers []string) (*Requester, error)
  • func (r *Requester) Close() error
  • func (r *Requester) Request(topic string, reqID string, payload []byte) ([]byte, error)
• type RiffTalk
  • func NewRiffTalk(k8sConfig, funcNamespace string) *RiffTalk
  • func (d RiffTalk) Create(fnName, image string) error
  • func (d RiffTalk) Delete(fnName string) error

Constants

const Accept = "Accept"

Accept is a constant for Accept

const ContentType = "Content-Type"

ContentType is a constant for Content-Type

Functions

func Close

func Close(i interface{})

Close provides a safe Close facility

Types

type Requester

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

func NewRequester

func NewRequester(requestIDKey, consumerGroupID string, kafkaBrokers []string) (*Requester, error)

func (*Requester) Close

func (r *Requester) Close() error

func (*Requester) Request

func (r *Requester) Request(topic string, reqID string, payload []byte) ([]byte, error)

type RiffTalk

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

func NewRiffTalk

func NewRiffTalk(k8sConfig, funcNamespace string) *RiffTalk

func (RiffTalk) Create

func (d RiffTalk) Create(fnName, image string) error

func (RiffTalk) Delete

func (d RiffTalk) Delete(fnName string) error