connections

Documentation

Index

• Constants
• type ABCIClient
• type APIClient
• type ConnectionContext
• type ConnectionInitializer
  • func NewConnectionManager(config *config.Config, logger log.Logger, ...) ConnectionInitializer
• type ConnectionManager
  • func NewFakeConnectionManager(clients map[string]ABCIClient) ConnectionManager
• type MockClient
  • func NewMockClient(ctrl *gomock.Controller) *MockClient
  • func (m *MockClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, ...) (*coretypes.ResultABCIQuery, error)
  • func (m *MockClient) BroadcastTxAsync(arg0 context.Context, arg1 types.Tx) (*coretypes.ResultBroadcastTx, error)
  • func (m *MockClient) BroadcastTxSync(arg0 context.Context, arg1 types.Tx) (*coretypes.ResultBroadcastTx, error)
  • func (m *MockClient) CheckTx(ctx context.Context, tx types.Tx) (*coretypes.ResultCheckTx, error)
  • func (m *MockClient) EXPECT() *MockClientMockRecorder
• type MockClientMockRecorder
  • func (mr *MockClientMockRecorder) ABCIQueryWithOptions(ctx, path, data, opts interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) BroadcastTxAsync(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) BroadcastTxSync(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockClientMockRecorder) CheckTx(ctx, tx interface{}) *gomock.Call
• type NetworkGroup
• type NodeMetrics
• type NodeStatus
• type StatusChecker

Constants

const UnhealthyNodeCheckInterval = time.Minute * 10 // TODO Configurable in toml?

Types

type ABCIClient

type ABCIClient interface {
	ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, opts client.ABCIQueryOptions) (*core.ResultABCIQuery, error)
	CheckTx(ctx context.Context, tx tm.Tx) (*core.ResultCheckTx, error)
	BroadcastTxAsync(context.Context, tm.Tx) (*core.ResultBroadcastTx, error)
	BroadcastTxSync(context.Context, tm.Tx) (*core.ResultBroadcastTx, error)
}

ABCIClient is a subset of from TM/rpc/client.ABCIClient.

type APIClient

type APIClient interface {
	RequestAPIv2(_ context.Context, method string, params, result interface{}) error
}

type ConnectionContext

type ConnectionContext interface {
	GetNetworkGroup() NetworkGroup
	GetNodeType() config.NodeType
	GetMetrics() *NodeMetrics
	GetAddress() string
	GetBasePort() int
	SetNodeUrl(addr *url.URL)
	GetABCIClient() ABCIClient
	GetAPIClient() APIClient
	IsHealthy() bool
	ReportError(err error)
	ReportErrorStatus(status NodeStatus)
	ClearErrors()
}

type ConnectionInitializer

type ConnectionInitializer interface {
	ConnectionManager
	InitClients(*local.Local, StatusChecker) error
	ConnectDirectly(other ConnectionManager) error
}

func NewConnectionManager

func NewConnectionManager(config *config.Config, logger log.Logger, apiClientFactory func(string) (APIClient, error)) ConnectionInitializer

type ConnectionManager

type ConnectionManager interface {
	SelectConnection(partitionId string, allowFollower bool) (ConnectionContext, error)
}

func NewFakeConnectionManager

func NewFakeConnectionManager(clients map[string]ABCIClient) ConnectionManager

type MockClient

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient is a mock of Client interface.

func NewMockClient

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) ABCIQueryWithOptions

func (m *MockClient) ABCIQueryWithOptions(ctx context.Context, path string, data bytes.HexBytes, opts client.ABCIQueryOptions) (*coretypes.ResultABCIQuery, error)

ABCIQueryWithOptions mocks base method.

func (*MockClient) BroadcastTxAsync

func (m *MockClient) BroadcastTxAsync(arg0 context.Context, arg1 types.Tx) (*coretypes.ResultBroadcastTx, error)

BroadcastTxAsync mocks base method.

func (*MockClient) BroadcastTxSync

func (m *MockClient) BroadcastTxSync(arg0 context.Context, arg1 types.Tx) (*coretypes.ResultBroadcastTx, error)

BroadcastTxSync mocks base method.

func (*MockClient) CheckTx

func (m *MockClient) CheckTx(ctx context.Context, tx types.Tx) (*coretypes.ResultCheckTx, error)

CheckTx mocks base method.

func (*MockClient) EXPECT

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockClientMockRecorder

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) ABCIQueryWithOptions

func (mr *MockClientMockRecorder) ABCIQueryWithOptions(ctx, path, data, opts interface{}) *gomock.Call

ABCIQueryWithOptions indicates an expected call of ABCIQueryWithOptions.

func (*MockClientMockRecorder) BroadcastTxAsync

func (mr *MockClientMockRecorder) BroadcastTxAsync(arg0, arg1 interface{}) *gomock.Call

BroadcastTxAsync indicates an expected call of BroadcastTxAsync.

func (*MockClientMockRecorder) BroadcastTxSync

func (mr *MockClientMockRecorder) BroadcastTxSync(arg0, arg1 interface{}) *gomock.Call

BroadcastTxSync indicates an expected call of BroadcastTxSync.

func (*MockClientMockRecorder) CheckTx

func (mr *MockClientMockRecorder) CheckTx(ctx, tx interface{}) *gomock.Call

CheckTx indicates an expected call of CheckTx.

type NetworkGroup

type NetworkGroup int

const (
	Local NetworkGroup = iota
	SamePartition
	OtherPartition
)

type NodeMetrics

type NodeMetrics struct {
	// contains filtered or unexported fields
}

type NodeStatus

type NodeStatus int

const (
	Up           NodeStatus = iota // Healthy & ready to go
	Down                           // Not reachable
	OutOfService                   // Reachable but not ready to go (IE. still syncing up)
	Unknown                        // Not checked yet
)

type StatusChecker

type StatusChecker interface {
	IsStatusOk(connCtx ConnectionContext) bool
}