bookkeeper

Documentation

Index

• Variables
• func InitBookieCluster(image, network, zookeeper string) *test.BaseContainer
• func ListBookies(containerID string) ([]string, error)
• type ClusterDef
  • func DefaultCluster() (*ClusterDef, error)
  • func NewBookieCluster(spec *ClusterSpec) (*ClusterDef, error)
  • func (c *ClusterDef) Close(ctx context.Context)
  • func (c *ClusterDef) GetAllBookieContainerID() []string
  • func (c *ClusterDef) GetHTTPServiceURL(ctx context.Context) (string, error)
  • func (c *ClusterDef) GetPlainTextServiceURL(ctx context.Context) (string, error)
  • func (c *ClusterDef) Start(ctx context.Context) error
  • func (c *ClusterDef) Stop(ctx context.Context) error
• type ClusterSpec
  • func DefaultClusterSpec() *ClusterSpec
  • func GetClusterSpec(spec *ClusterSpec) *ClusterSpec

Variables

var (
	LatestImage      = "apache/bookkeeper:latest"
	BookKeeper4_10_0 = "apache/bookkeeper:4.10.0"
)

Functions

func InitBookieCluster

func InitBookieCluster(image, network, zookeeper string) *test.BaseContainer

func ListBookies

func ListBookies(containerID string) ([]string, error)

Types

type ClusterDef

type ClusterDef struct {
	test.Cluster
	// contains filtered or unexported fields
}

func DefaultCluster

func DefaultCluster() (*ClusterDef, error)

func NewBookieCluster

func NewBookieCluster(spec *ClusterSpec) (*ClusterDef, error)

func (*ClusterDef) Close

func (c *ClusterDef) Close(ctx context.Context)

func (*ClusterDef) GetAllBookieContainerID

func (c *ClusterDef) GetAllBookieContainerID() []string

func (*ClusterDef) GetHTTPServiceURL

func (c *ClusterDef) GetHTTPServiceURL(ctx context.Context) (string, error)

func (*ClusterDef) GetPlainTextServiceURL

func (c *ClusterDef) GetPlainTextServiceURL(ctx context.Context) (string, error)

func (*ClusterDef) Start

func (c *ClusterDef) Start(ctx context.Context) error

func (*ClusterDef) Stop

func (c *ClusterDef) Stop(ctx context.Context) error

type ClusterSpec

type ClusterSpec struct {
	Image                 string
	ClusterName           string
	NumBookies            int
	BookieServicePort     int
	BookieHTTPServicePort int
	ZookeeperServicePort  int
	BookieEnv             map[string]string
}

func DefaultClusterSpec

func DefaultClusterSpec() *ClusterSpec

func GetClusterSpec

func GetClusterSpec(spec *ClusterSpec) *ClusterSpec