glink

README

glink

Open source Stream processing framework based on Golang

Documentation

Index

• func ClusterManager(url string, token string) (res *clusterManager)
• func StandaloneManager() (res *standaloneManager)
• type Config
• type IManager
• type ITaskSetup
  • func Cluster(url string, token string) ITaskSetup
  • func New(manager IManager) ITaskSetup
  • func Standalone() ITaskSetup

Functions

func ClusterManager

func ClusterManager(url string, token string) (res *clusterManager)

func StandaloneManager

func StandaloneManager() (res *standaloneManager)

Types

type Config

type Config struct {
	Name string
}

type IManager

type IManager interface {
	Error(err error)
}

type ITaskSetup

type ITaskSetup interface {
	Task(name string, input func(input stream.IInputStream), watermark ...func(interface{}) time.Time) *stream.DataStream
	Run()
}

func Cluster

func Cluster(url string, token string) ITaskSetup

func New

func New(manager IManager) ITaskSetup

func Standalone

func Standalone() ITaskSetup