orderer

Documentation

Index

• Constants
• type IBPOperatorClient
• type Kube
• type Orderer
  • func New(logger *zap.Logger, k8sClient Kube, ibpClient IBPOperatorClient, ...) *Orderer
  • func (o *Orderer) Create(domain, compName, namespace, version, sID string, spec *current.IBPOrdererSpec) ([]api.Response, int, error)
  • func (o *Orderer) CreateCR(domain, sID, compName, namespace string, body []byte) ([]api.Response, int, error)
  • func (o *Orderer) CreateCluster(domain, sID, compName string, body []byte) ([]api.Response, int, error)
  • func (o *Orderer) DeleteCR(sID, compName, namespace string, body []byte) (*api.DeleteResponse, int, error)
  • func (o *Orderer) GetAllCR(sID, namespace string) ([]api.Response, int, error)
  • func (o *Orderer) GetCR(section, compName, namespace, sID string) (*api.Response, int, error)
  • func (o *Orderer) GetCRResponse(section, compName, namespace, sID string) (*api.Response, int, error)
  • func (o *Orderer) GetConfig(compName, namespace string, fabricVersion string) (interface{}, error)
  • func (o *Orderer) GetConnectionProfile(compName, namespace string) (*common.ConnectionProfile, error)
  • func (o *Orderer) GetIndividualResources(allResources *current.OrdererResources) *current.OrdererResources
  • func (o *Orderer) GetResources(defaults *dconfig.DeployerDefaults, override *current.OrdererResources) *current.OrdererResources
  • func (o *Orderer) GetStorage(defaults *dconfig.DeployerDefaults, override *current.OrdererStorages) *current.OrdererStorages
  • func (o *Orderer) GetUpdateResources(current, override *current.OrdererResources) (*current.OrdererResources, error)
  • func (o *Orderer) Images(version string) *current.OrdererImages
  • func (o *Orderer) PatchCR(section, compName, namespace, sID string, body []byte) (*api.Response, int, error)
  • func (o *Orderer) PrecreateCR(domain, sID string, body []byte, compName string) (*api.Response, int, error)
  • func (o *Orderer) UpdateCR(section, compName, namespace, sID string, body []byte) (*api.Response, int, error)

Constants

const (
	PortNameOperations      = "operations"
	PortNameOrdererGrpc     = "orderer-grpc"
	PortNameGrpcWeb         = "grpcweb"
	EndpointHttpURLTemplate = "https://%s:%s"
	EndpointGrpcURLTemplate = "grpcs://%s:%s"
)

const (
	ACTIONS    = "actions"
	RESOURCES  = "resources"
	CONFIG     = "config"
	CRYPTO     = "crypto"
	ADMINCERTS = "admincerts"
	NODEOU     = "nodeou"
	STORAGE    = "storage"
	STATUS     = "status"
	ENDPOINTS  = "endpoints"
	VERSION    = "version"
	REPLICAS   = "replicas"
	GENESIS    = "genesis"
	HSM        = "hsm"
	ALL        = "all"
)

Supported actions for Orderer

Types

type IBPOperatorClient

type IBPOperatorClient interface {
	GetCR(namespace string, kind string, name string, cr runtime.Object) error
	GetAllCR(namespace string, kind string, cr runtime.Object) error
	CreateCR(namespace string, kind string, cr interface{}) error
	DeleteCR(namespace string, kind string, name string) error
	UpdateCR(namespace string, kind string, name string, bytes []byte) error
	PatchCR(namespace string, kind string, name string, bytes []byte) error
}

type Kube

type Kube interface {
	GetNamespaces() (*corev1.NamespaceList, error)
	GetService(namespace, name string) (*corev1.Service, error)
	GetConfigMap(namespace, name string) (*corev1.ConfigMap, error)
	DeleteAndCreateSecret(namespace string, secret *corev1.Secret) (*corev1.Secret, error)
	DeleteSecret(namespace string, name string) error
	GetPort(namespace, name string) (int32, error)
	GetPorts(namespace, name string) ([]corev1.ServicePort, error)
	GetSecret(namespace string, name string) (*corev1.Secret, error)
	UpdateSecret(namespace, name, path string, data []byte) (*corev1.Secret, error)
	DeleteDeployment(namespace string, depName string) error
	GetPodsByLabel(namespace, name string) (*corev1.Pod, error)
}

type Orderer

type Orderer struct {
	Kube              Kube
	Logger            *zap.SugaredLogger
	IBPOperatorClient IBPOperatorClient
	Config            *dconfig.DeployerSettingsConfig
}

func New

func New(logger *zap.Logger, k8sClient Kube, ibpClient IBPOperatorClient, config *dconfig.DeployerSettingsConfig) *Orderer

func (*Orderer) Create

func (o *Orderer) Create(domain, compName, namespace, version, sID string, spec *current.IBPOrdererSpec) ([]api.Response, int, error)

func (*Orderer) CreateCR

func (o *Orderer) CreateCR(domain, sID, compName, namespace string, body []byte) ([]api.Response, int, error)

func (*Orderer) CreateCluster

func (o *Orderer) CreateCluster(domain, sID, compName string, body []byte) ([]api.Response, int, error)

func (*Orderer) DeleteCR

func (o *Orderer) DeleteCR(sID, compName, namespace string, body []byte) (*api.DeleteResponse, int, error)

func (*Orderer) GetAllCR

func (o *Orderer) GetAllCR(sID, namespace string) ([]api.Response, int, error)

func (*Orderer) GetCR

func (o *Orderer) GetCR(section, compName, namespace, sID string) (*api.Response, int, error)

func (*Orderer) GetCRResponse

func (o *Orderer) GetCRResponse(section, compName, namespace, sID string) (*api.Response, int, error)

func (*Orderer) GetConfig

func (o *Orderer) GetConfig(compName, namespace string, fabricVersion string) (interface{}, error)

func (*Orderer) GetConnectionProfile

func (o *Orderer) GetConnectionProfile(compName, namespace string) (*common.ConnectionProfile, error)

func (*Orderer) GetIndividualResources

func (o *Orderer) GetIndividualResources(allResources *current.OrdererResources) *current.OrdererResources

func (*Orderer) GetResources

func (o *Orderer) GetResources(defaults *dconfig.DeployerDefaults, override *current.OrdererResources) *current.OrdererResources

func (*Orderer) GetStorage

func (o *Orderer) GetStorage(defaults *dconfig.DeployerDefaults, override *current.OrdererStorages) *current.OrdererStorages

func (*Orderer) GetUpdateResources

func (o *Orderer) GetUpdateResources(current, override *current.OrdererResources) (*current.OrdererResources, error)

func (*Orderer) Images

func (o *Orderer) Images(version string) *current.OrdererImages

func (*Orderer) PatchCR

func (o *Orderer) PatchCR(section, compName, namespace, sID string, body []byte) (*api.Response, int, error)

func (*Orderer) PrecreateCR

func (o *Orderer) PrecreateCR(domain, sID string, body []byte, compName string) (*api.Response, int, error)

precreate creates a CR spec with directly the orderer node spec we need to give it name and number and leave the genesis block blank

func (*Orderer) UpdateCR

func (o *Orderer) UpdateCR(section, compName, namespace, sID string, body []byte) (*api.Response, int, error)