flowgrpc

package

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

Details

View Source

const (
	// MetricFlowStatus is the metric name for the Flow gRPC health status
	MetricFlowStatus = "flow_grpc_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 NewFlowGrpcManager(superForge *elektratypes.Elektra, superAPI *Manager.ManagerAPI, superConf *Manager.ManagerConf) *API

NewFlowGrpcManager - returns a new instance of helm manager

func (flowgrpc *API) CreateGrpcClient() error

CreateGrpcClient creates the Flow gRPC client, this is called at Site Agent startup and will be retried until it succeeds

func (flowgrpc *API) GetGrpcClient() *client.FlowGrpcClient

GetGrpcClient gets the Flow gRPC client

func (flowgrpc *API) GetGrpcClientVersion() int64

GetGrpcClientVersion returns the current version of the Flow gRPC client

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

GetState returns the current state of the Flow gRPC client manager

func (flowgrpc *API) Init()

Init initializes the Flow gRPC client manager

func (flowgrpc *API) RegisterSubscriber() error

RegisterSubscriber registers Flow rack and tray workflows and activities with Temporal

func (flowgrpc *API) Start()

Start starts the Flow gRPC client manager

func (flowgrpc *API) UpdateGrpcClientState(err error)

UpdateGrpcClientState updates the Flow gRPC client state