output

Documentation

Overview

Copyright (c) 2023 Albert Espín albert@espin.ovh

Copyright (c) 2023 Albert Espín albert@espin.ovh

Index

• type DataWareHouse
  • func NewDataWareHouse(config *DataWareHouseConfig, net *fb.Network, log logger.LoggerAdapter) *DataWareHouse
  • func (d *DataWareHouse) In() *fb.InPort
  • func (d *DataWareHouse) Out() *fb.OutPort
  • func (d *DataWareHouse) Run()
• type DataWareHouseConfig
• type ObjectConfig
• type TCPClient
  • func NewTCPClient(config *TCPClientConfig, net *fb.Network, log logger.LoggerAdapter) *TCPClient
  • func (c *TCPClient) Close()
  • func (c *TCPClient) In() *fb.InPort
  • func (c *TCPClient) Out() *fb.OutPort
  • func (c *TCPClient) Run()
• type TCPClientConfig
• type WebSocketServer
  • func NewWebSocketServer(config *WebSocketServerConfig, Net *fb.Network, log logger.LoggerAdapter) *WebSocketServer
  • func (s *WebSocketServer) In() *fb.InPort
  • func (s *WebSocketServer) Init() error
  • func (s *WebSocketServer) Out() *fb.OutPort
  • func (s *WebSocketServer) Run()
• type WebSocketServerConfig

Types

type DataWareHouse

type DataWareHouse struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewDataWareHouse

func NewDataWareHouse(config *DataWareHouseConfig, net *fb.Network, log logger.LoggerAdapter) *DataWareHouse

func (*DataWareHouse) In

func (d *DataWareHouse) In() *fb.InPort

func (*DataWareHouse) Out

func (d *DataWareHouse) Out() *fb.OutPort

func (*DataWareHouse) Run

func (d *DataWareHouse) Run()

type DataWareHouseConfig

type DataWareHouseConfig struct {
	ProcessName     string
	Endpoint        string
	AccessKeyID     string
	SecretAccessKey string
	UseSSL          bool
	Object          ObjectConfig
}

type ObjectConfig

type ObjectConfig struct {
	Bucket      string
	ContentType string
	Location    string
}

type TCPClient

type TCPClient struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewTCPClient

func NewTCPClient(config *TCPClientConfig, net *fb.Network, log logger.LoggerAdapter) *TCPClient

func (*TCPClient) Close

func (c *TCPClient) Close()

func (*TCPClient) In

func (c *TCPClient) In() *fb.InPort

func (*TCPClient) Out

func (c *TCPClient) Out() *fb.OutPort

func (*TCPClient) Run

func (c *TCPClient) Run()

type TCPClientConfig

type TCPClientConfig struct {
	ProcessName     string
	Network         string
	Address         string
	RetryInterval   time.Duration
	KeepAlivePeriod time.Duration
}

type WebSocketServer

type WebSocketServer struct {
	fb.BaseProcess
	// contains filtered or unexported fields
}

func NewWebSocketServer

func NewWebSocketServer(config *WebSocketServerConfig, Net *fb.Network, log logger.LoggerAdapter) *WebSocketServer

func (*WebSocketServer) In

func (s *WebSocketServer) In() *fb.InPort

func (*WebSocketServer) Init

func (s *WebSocketServer) Init() error

func (*WebSocketServer) Out

func (s *WebSocketServer) Out() *fb.OutPort

func (*WebSocketServer) Run

func (s *WebSocketServer) Run()

type WebSocketServerConfig

type WebSocketServerConfig struct {
	ProcessName string
	Url         string
	BindAddr    string
}