client

Documentation

Index

• type NegotiationPayload
• type ServerlessClient
  • func NewServerless(appName string) ServerlessClient
• type SourceClient
  • func NewSource(appName string) SourceClient
• type ZipperSenderClient
  • func NewZipperSender(appName string) ZipperSenderClient

Types

type NegotiationPayload

type NegotiationPayload struct {
	AppName    string `json:"app_name"`
	ClientType string `json:"client_type"`
}

NegotiationPayload represents the payload for negotiation.

type ServerlessClient

type ServerlessClient interface {

	// Connect to YoMo-Zipper
	Connect(ip string, port int) (ServerlessClient, error)

	// Pipe the Handler function.
	Pipe(f func(rxstream rx.RxStream) rx.RxStream)
	// contains filtered or unexported methods
}

ServerlessClient is the client for YoMo-Serverless.

func NewServerless

func NewServerless(appName string) ServerlessClient

NewServerless setups the client of YoMo-Serverless. The "appName" should match the name of flows (or sinks) in workflow.yaml in zipper.

type SourceClient

type SourceClient interface {

	// Connect to YoMo-Zipper
	Connect(ip string, port int) (SourceClient, error)
	// contains filtered or unexported methods
}

SourceClient is the client for YoMo-Source. https://yomo.run/source

func NewSource

func NewSource(appName string) SourceClient

NewSource setups the client of YoMo-Source.

type ZipperSenderClient

type ZipperSenderClient interface {

	// Connect to downsteam Zipper-Receiver
	Connect(ip string, port int) (ZipperSenderClient, error)
	// contains filtered or unexported methods
}

ZipperSenderClient is the client for Zipper-Sender to connect the downsteam Zipper-Receiver in edge-mesh.

func NewZipperSender

func NewZipperSender(appName string) ZipperSenderClient

NewZipperSender setups the client of Zipper-Sender.