riff

package

v0.2.0-alpha Latest Latest Go to latest Published: Oct 19, 2018 License: Apache-2.0 Imports: 19 Imported by: 2

Details

View Source

const Accept = "Accept"

Accept is a constant for Accept

View Source

const ContentType = "Content-Type"

ContentType is a constant for Content-Type

This section is empty.

func Close(i interface{})

Close provides a safe Close facility

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

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

func (r *Requester) Close() error

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

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

func NewRiffTalk(k8sConfig, funcNamespace string) *RiffTalk

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

func (d RiffTalk) Delete(fnName string) error