output

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 23, 2023 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

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

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL