grpc_client

type CallPropertiesProvider interface {
	CallOptions(context.Context) []grpc.CallOption
}

type Connection struct {
	Tag        ConnectionTag
	Connection ConnectionDesc
	// contains filtered or unexported fields
}

type ConnectionDesc = *grpc.ClientConn

type ConnectionPool interface {
	GetStableConnection(context.Context) (*grpc.ClientConn, error)
	Reconnect(context.Context) (*grpc.ClientConn, error)
}

type ConnectionPropertiesProvider interface {
	DialOptions(context.Context) ([]grpc.DialOption, error)
	Tag(context.Context) (ConnectionTag, error)
	Validate(*ConnectionTag, *ConnectionTag) bool
}

type ConnectionStatus struct {
	Kind    ConnectionStatusKind
	Attempt int
}

type ConnectionStatusKind string

type ConnectionTag struct {
	Key      string
	UserData interface{}
}

type ConnectionsMap map[string]*Connection

type DefaultConnectionProps struct{}

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

type GRPCClientInterface interface {
	ConnectionPropertiesProvider
	CallPropertiesProvider

	// NOTE: This method returns Droppable list item, making its clients able to
	// subscribe for connection related events
	ConnStatusChannel() *dllist.ListItem[StatusSub]
}

type StatusSub = *dchannel.DynamicChannel[ConnectionStatus]