flow

package

v1.5.1 Latest Latest Go to latest Published: May 14, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

View Source

const (
	// MetricFlowStatus - Metric Flow Status
	MetricFlowStatus = "flow_health_status"
)

View Source

var ManagerAccess *Manager.ManagerAccess

ManagerAccess - access to all managers

This section is empty.

type API struct{} //nolint:all

API - all API interface

func NewFlowManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, superConf *Manager.ManagerConf) *API

NewFlowManager - returns a new instance of helm manager

func (Flow *API) CreateGRPCClient() error

CreateGRPCClient - creates the grpc connection handle

func (Flow *API) CreateGRPCClientActivity(ctx context.Context, ResourceID string) (client *client.FlowClient, err error)

CreateGRPCClientActivity - Create GRPC client Activity

func (Flow *API) GetGRPCClient() *client.FlowClient

GetGRPCClient - gets the grpc connection handle

func (f *API) GetGRPCClientVersion() int64

GetGrpcClientVersion returns the current version of the GRPC client

func (f *API) GetState() []string

GetState Machine

func (f *API) Init()

Init - initialize Flow manager

func (Flow *API) RegisterGRPC()

RegisterGRPC - Register GRPC

func (api *API) RegisterSubscriber() error

RegisterSubscriber registers Flow rack and tray workflows and activities with Temporal

func (f *API) Start()

Start - Start Flow manager

func (Flow *API) UpdateGRPCClientState(err error)

UpdateGRPCClientState - updates Flow state