mainchannel

Documentation

Index

• Variables
• func CreateConfigUpdateEnvelope(channelID string, configUpdate *common.ConfigUpdate) ([]byte, error)
• type FabricMainChannelReconciler
  • func (r *FabricMainChannelReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *FabricMainChannelReconciler) SetupWithManager(mgr ctrl.Manager) error
• type Pem

Variables

var DefaultConfig = sb.Options{
	RequestBatchMaxCount:      types.DefaultConfig.RequestBatchMaxCount,
	RequestBatchMaxBytes:      types.DefaultConfig.RequestBatchMaxBytes,
	RequestBatchMaxInterval:   types.DefaultConfig.RequestBatchMaxInterval.String(),
	IncomingMessageBufferSize: types.DefaultConfig.IncomingMessageBufferSize,
	RequestPoolSize:           types.DefaultConfig.RequestPoolSize,
	RequestForwardTimeout:     types.DefaultConfig.RequestForwardTimeout.String(),
	RequestComplainTimeout:    types.DefaultConfig.RequestComplainTimeout.String(),
	RequestAutoRemoveTimeout:  types.DefaultConfig.RequestAutoRemoveTimeout.String(),
	ViewChangeResendInterval:  types.DefaultConfig.ViewChangeResendInterval.String(),
	ViewChangeTimeout:         types.DefaultConfig.ViewChangeTimeout.String(),
	LeaderHeartbeatTimeout:    types.DefaultConfig.LeaderHeartbeatTimeout.String(),
	LeaderHeartbeatCount:      types.DefaultConfig.LeaderHeartbeatCount,
	CollectTimeout:            types.DefaultConfig.CollectTimeout.String(),
	SyncOnStart:               types.DefaultConfig.SyncOnStart,
	SpeedUpViewChange:         types.DefaultConfig.SpeedUpViewChange,
	LeaderRotation:            sb.Options_ROTATION_ON,
	DecisionsPerLeader:        3,
	RequestMaxBytes:           10 * 1024,
}

var (
	ErrClientK8s = errors.New("k8sAPIClientError")
)

Functions

func CreateConfigUpdateEnvelope

func CreateConfigUpdateEnvelope(channelID string, configUpdate *common.ConfigUpdate) ([]byte, error)

Types

type FabricMainChannelReconciler

type FabricMainChannelReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
	Config *rest.Config
}

FabricMainChannelReconciler reconciles a FabricMainChannel object

func (*FabricMainChannelReconciler) Reconcile

func (r *FabricMainChannelReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricmainchannels,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricmainchannels/status,verbs=get;update;patch +kubebuilder:rbac:groups=hlf.kungfusoftware.es,resources=fabricmainchannels/finalizers,verbs=get;update;patch

func (*FabricMainChannelReconciler) SetupWithManager

func (r *FabricMainChannelReconciler) SetupWithManager(mgr ctrl.Manager) error

type Pem

type Pem struct {
	Pem string
}